rx-java之如何使用 takeWhile 发出最后一个元素
程序猿
阅读:32
2024-06-03 14:00:57
评论:0
我有一个从元素开始发出项目的流。我知道是哪个元素。一旦该元素被发射,流就不会发射更多。问题是它不会发出 onComplete。我需要更多类似 takeWhile
的东西但也发出最后一个元素。这是弹珠的想法:
(从ReactiveX TakeWhile中提取的原始图像)
我可以使用哪个或哪些运算符来执行此操作?
请您参考如下方法:
只是重复我的评论:
运算符(operator)叫takeUntil
用Func1<T, Boolean>
谓词参数:
http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeUntil(rx.functions.Func1)
声明
1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,请转载时务必注明文章作者和来源,不尊重原创的行为我们将追究责任;3.作者投稿可能会经我们编辑修改或补充。