我有一個(gè)集合,其中包含了若干Message對象。我想通過RxJava從集合中每隔一秒依次發(fā)送集合中的對象我一開始的時(shí)候想這樣操作,發(fā)現(xiàn)一次也不發(fā)送對象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));但是發(fā)現(xiàn)集合一瞬間就被發(fā)送完了。并沒有被延時(shí)。有什么辦法可以延時(shí)發(fā)送集合嗎?delay(1s)delay(1s)delay(1s)0----------->1----------->2----------->3...
RxJava怎么定時(shí)依次發(fā)送集合的每個(gè)元素?
九州編程
2019-05-24 16:03:25