我使用的是RxJava3,我有下面的代码设置,我想在第一个和第二个流动之间的中间发出一个项。有办法做到吗?
firstFlowable.firstElement()
//I want to emit an item here
.flatMap { secondFlowable.firstElement() }
我之所以要这样做,是因为在firstFlowable
初始化之后,还有很长一段时间直到secondFlowable
初始化,我想用一条消息通知UI操作已经开始,我正在等待来自secondFlowable
的数据计算。
我尝试使用startWithItem
,但这在一开始就初始化了我的整个链,但我只想在firstFlowable
产生第一个值后发出。
您可以使用merge注入一个值,然后根据值类型进行操作。如果secondFlowable
立即结束,您可能希望避免通过takeUntil
显示字符串。
firstFlowable.firstElement()
.flatMap(v ->
Maybe.<Object>merge(
secondFlowable.firstElement(),
Maybe.just("Second in progress")
)
)
.takeUntil(v -> !(v instanceof String))
.observeOn(mainThread())
.subscribe(v -> {
if (v instanceof String) {
// display message here
} else {
// cast and display results of second
}
});
也许您可以将concatWith()
与take()
和skip()
一起用于firstFlowable
。
public static void main(String[] args) {
Flowable<String> firstFlowable = Flowable.just("1st", "2nd", "3rd", "4th", "5th");
Flowable<String> middleFlowable = Flowable.just("between");
Flowable<String> secondFlowable = Flowable.just("A", "B", "C", "D");
firstFlowable.take(1)
.concatWith(middleFlowable)
.concatWith(firstFlowable.skip(1))
.concatWith(secondFlowable)
.subscribe(System.out::println);
Flowable.timer(10, SECONDS).blockingSubscribe(); // Just to block the main thread for a while
}
这给出了类似的东西:
1st
between
2nd
3rd
4th
5th
A
B
C
D