I want my observable to fire immediately, and again every second. interval
will not fire immediately. I found this question which suggested using startWith
, which DOES fire immediately, but I then get a duplicate first entry.
Rx.Observable.interval(1000).take(4).startWith(0).subscribe(onNext);
https://plnkr.co/edit/Cl5DQ7znJRDe0VTv0Ux5?p=preview
How can I make interval fire immediately, but not duplicate the first entry?
Observable.timer(0, 1000)
will start immediately.or with timer:
With RxJava2, there's no issue with duplicated first entry and this code is working fine:
Note you need to pass
Long
in startWith, so0L
.