close
return timer會一直重複發射RX流,直到發射onComplete時候停止
.repeatWhen(objectObservable -> objectObservable.flatMap(o -> { if(++index > 5) { return Observer::onComplete; }else{ return objectObservable.timer(1,TimeUnit.SECONDS); } }) )
全站熱搜