【发布时间】:2018-04-19 10:49:04
【问题描述】:
我想在Flowable 中的所有项目都发出后发出最后一个项目。现在我可以通过以下代码实现这一点。
Flowable<String> flowable = getFlowable();
flowable.toList()
.toFlowable()
.flatMap(stringList -> {
stringList.add("final String");
return Flowable.just(stringList);
})
.subscribe(System.out::println);
问题是,它要等到所有项目都获得后才发出。我希望它们在获得时立即发出,一次一个,并且可以在最后一项之后立即发出额外的final String,如何实现?
【问题讨论】: