Throttling calls for searching in Swift

Throttling is mainly used for the searching tasks whenever a user types fast to make sure that, backend server doesn’t receive multiple requests. if you send multiple requests to the server and canceling the request it increases the load on the server if the server is paid and it also increases the cost too much.

Best way to implement is throttler by using the RxSwift but the question is for the single task why you use RxSwift the better way you can use the GCD for this.

For implementing throttler you can use the DispatchWorkItem from this you can set a pause to the request or on a task and cancel the previous task. Check the implementation of throttler:-

class Throttler {
    private var searchTask: DispatchWorkItem?

    deinit {
        print("Throttler object deiniantialized")
    }
    func throttle(searchText: String, block: @escaping (_ products: [ProductData]) -> Void) {
        searchTask?.cancel()
       let task = DispatchWorkItem { [weak self] in
            guard let obj = self else {
                return
            }
          //  obj.getSearchProducts(searchText: searchText) { (products) in
            //     block(products)
          //  }
          // here you hit the request and get back the data
        }
        self.searchTask = task
        DispatchQueue.main.asyncAfter(deadline: DispatchTime.now() + 0.5, execute: task)
    }
}

class Throttler {

private var searchTask: DispatchWorkItem?

deinit {

print("Throttler object deiniantialized")

}

func throttle(searchText: String, block: @escaping (_ products: [ProductData]) -> Void) {

searchTask?.cancel()

let task = DispatchWorkItem { [weak self] in

guard let obj = self else {

return

}

// obj.getSearchProducts(searchText: searchText) { (products) in

// block(products)

// }

// here you hit the request and get back the data

}

self.searchTask = task

DispatchQueue.main.asyncAfter(deadline: DispatchTime.now() + 0.5, execute: task)

}

How to use it:-

 private var throttler: Throttler?
    /// Event received when a change into the search box is occurred

    override func searchBar(_ searchBar: UISearchBar, textDidChange searchText: String) {
        defer {
            self.throttler?.throttle(searchText: searchText) { [weak self] (products) in
                self?.throttler = nil
                self?.delegate?.shareSearchData(products: products)
            }
        }
        guard self.throttler != nil else {
            self.throttler = Throttler()
            return
        }
    }

private var throttler: Throttler?

/// Event received when a change into the search box is occurred

override func searchBar(_ searchBar: UISearchBar, textDidChange searchText: String) {

defer {

self.throttler?.throttle(searchText: searchText) { [weak self] (products) in

self?.throttler = nil

self?.delegate?.shareSearchData(products: products)

}

guard self.throttler != nil else {

self.throttler = Throttler()

return

}

I hope from this, it will make you more comfortable dealing with Throttling calls. Thanks for tuning in once again!

bhavuk chawla 9 December 2018

. . .

Throttling calls for searching in Swift

Leave a Comment Cancel Reply

Message Sent!