之间有什么区别：
Observable<String> observable = Observable
.interval(0,1,TimeUnit.SECONDS)
.flatMap(new Func1<Long,Observable<String>>() {
@Override
public Observable<String> call(Long aLong) {
return Observable.just("MyString");
}
})
和：
Observable<String> observable = Observable.just("MyString")
.repeatWhen(new Func1<Observable<? extends Void>,Observable<?>>() {
@Override
public Observable<?> call(Observable<? extends Void> completed) {
return completed.delay(1,TimeUnit.SECONDS);
}
})
第二个是更清洁但实际上并考虑到背压,这两种解决方案的行为方式是否相同？
解决方法
根据您的source observable(在这种情况下只是(“MyString”)),可能会有一些差异：
> interval()将每秒运行一次(如果可能),而repeatWhen()将始终延迟()1秒.对于just()这没关系,但是如果你的源需要一段时间来运行(例如500ms)那么你会看到时间上的差异：interval()将重新订阅每1,000ms,但repeatWhen(delay())将运行每1,500ms(500ms输出1,000ms延迟).
如果你的源需要超过一秒钟,那么每个resubscription与interval()之间不会有暂停,因为它只会等到前一个flatMap()完成后再执行另一个！
>如果在flatMap()中使用调度程序,则可以实现repeatWhen()无法实现的某些并行化.同样,这对于just()来说并不重要,但它适用于长期运行的Observable.有关更多信息,请查看this great article.
我不相信这两者之间存在差异,更熟悉RxJava内部的人可能会指出更多.
