CoroutineWorker

delay

class BatchedLoader(private val loader: () -> String) {

    private val requests = PublishSubject<Unit>()

    init {
        requests
            .throttle(windowMillis = 1000L)
            .observeOn(ioScheduler)
            .map { loader() }
            .observeOn(mainScheduler)
            .subscribe { result: String ->
                // Do something with the result
            }
    }

    fun load() {
        requests.onNext(Unit)
    }
}