Kris Wong
02/11/2020, 4:59 PMKris Wong
02/11/2020, 5:04 PMCoroutineWorker
with a delay
Arkadii Ivanov
02/11/2020, 5:14 PMKris Wong
02/11/2020, 5:20 PMArkadii Ivanov
02/11/2020, 5:46 PMKris Wong
02/11/2020, 7:30 PMArkadii Ivanov
02/11/2020, 7:51 PMArkadii Ivanov
02/12/2020, 12:11 AMclass 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)
}
}