After the specified time, this reactive source signals a single 0L
(then completes for Flowable
and Observable
).
Observable<Long> eggTimer = Observable.timer(5, TimeUnit.MINUTES); eggTimer.blockingSubscribe(v -> System.out.println("Egg is ready!"));
Refereneces
https://github.com/ReactiveX/RxJava/wiki/Creating-Observables#timer
http://reactivex.io/documentation/operators/timer.html