so the only solution is use Scheduler.single() ? ...
# rx
u
so the only solution is use Scheduler.single() ?
Copy code
val scheduler = Schedulers.single()
scanResults()
.observeOn(scheduler)
.takeUntil(timer(foo, scheduler).map { someSpecialValue })