anyone aware of a multiplatform way to execute some work after a delay (in order to coalesce multipl...

# multiplatform

[Kris Wong]

anyone aware of a multiplatform way to execute some work after a delay (in order to coalesce multiple requests)?

[Kris Wong]

i suppose i could just use CoroutineWorker with a delay

[Arkadii Ivanov]

What you mean by "coalesce multiple requests"?

[Kris Wong]

n number of requests becomes 1

[Arkadii Ivanov]

Sorry still not clear to me. Do you mean batching multiple consecutive requests (within a time window) into one? Or to execute a request and any following requests should join the first one?

[Kris Wong]

the former

[Arkadii Ivanov]

Then I believe things are a little bit more complicated than just delay. If I understood you correctly. Need to think about it.

[Arkadii Ivanov]

So I would do something like this with Reaktive

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)
    }
}