我有一個集合,其中包含了若干Message對象。我想通過RxJava從集合中每隔一秒依次發送集合中的對象我一開始的時候想這樣操作,發現一次也不發送對象FlowablemessageFlowable=Flowable.fromIterable(mock.messages);FlowabletimeFlowable=Flowable.interval(1,TimeUnit.SECONDS);Flowableflowable=Flowable.zip(messageFlowable,timeFlowable,newBiFunction(){@OverridepublicStringapply(Messagemessage,LongaLong)throwsException{returnmessage.content;}});flowable.subscribe(/*....*/)后來我就想用這種方式Flowable.fromIterable(mock.messages).map(message->message.content).delay(1,TimeUnit.SECONDS).subscribe(s->Timber.d("s=%s",s));但是發現集合一瞬間就被發送完了。并沒有被延時。有什么辦法可以延時發送集合嗎?delay(1s)delay(1s)delay(1s)0----------->1----------->2----------->3...
RxJava怎么定時依次發送集合的每個元素?
九州編程
2019-05-24 16:03:25