如何在没有延迟的情况下立即启动Observable Interval？

Question

我希望我的观察能够立即射击,并且每秒钟都会射击.interval不会立即开火.我发现这个问题建议使用startWith,哪个会立即触发,但我得到一个重复的第一个条目.

  Rx.Observable.interval(1000).take(4).startWith(0).subscribe(onNext);

https://plnkr.co/edit/Cl5DQ7znJRDe0VTv0Ux5?p=preview

如何立即点火,但不能复制第一个条目？

Answer 1

Observable.timer(0,1000)将立即启动.

Answer 2

RxJs 6

interval(100).pipe(startWith(0)).subscribe(() => { //your code }); 

或使用计时器：

import {timer} from 'rxjs/observable/timer';
timer(0, 100).subscribe(() => {

    });

Answer 3

使用RxJava2，重复的第一项没有问题，并且此代码可以正常工作：

io.reactivex.Observable.interval(1, TimeUnit.SECONDS)
        .startWith(0L)
        .subscribe(aLong -> {
            Log.d(TAG, "test");    // do whatever you want
    });

注意，您需要传递LongstartWith，所以0L。