ursus
val scheduler = Schedulers.single() scanResults() .observeOn(scheduler) .takeUntil(timer(foo, scheduler).map { someSpecialValue })