rx-java之如何使用 takeWhile 发出最后一个元素

程序猿 阅读:32 2024-06-03 14:00:57 评论:0

我有一个从元素开始发出项目的流。我知道是哪个元素。一旦该元素被发射,流就不会发射更多。问题是它不会发出 onComplete。我需要更多类似 takeWhile 的东西但也发出最后一个元素。这是弹珠的想法:

(从ReactiveX TakeWhile中提取的原始图像)

我可以使用哪个或哪些运算符来执行此操作?

请您参考如下方法:

只是重复我的评论:

运算符(operator)叫takeUntilFunc1<T, Boolean>谓词参数:

http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeUntil(rx.functions.Func1)


标签:java
声明

1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。

关注我们

一个IT知识分享的公众号