如何使用 takeWhile 发出最后一个元素？
How to emmit the last element ussing takeWhile?
我有一个流，它从一个元素开始发出项目。我知道是哪个元素。一旦该元素被发射，流就不会发射更多。问题是它不会发出 onComplete。我需要的东西不像 takeWhile 但也发出最后一个元素。这是弹珠的想法：
（从ReactiveX TakeWhile中提取的原始图像）
我可以使用哪个或哪些运算符来执行此操作？
只是重复我的评论：
使用 Func1<T, Boolean> 谓词参数调用运算符 takeUntil：
http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeUntil(rx.functions.Func1)
我有一个流，它从一个元素开始发出项目。我知道是哪个元素。一旦该元素被发射，流就不会发射更多。问题是它不会发出 onComplete。我需要的东西不像 takeWhile 但也发出最后一个元素。这是弹珠的想法：
（从ReactiveX TakeWhile中提取的原始图像）
我可以使用哪个或哪些运算符来执行此操作？
只是重复我的评论：
使用 Func1<T, Boolean> 谓词参数调用运算符 takeUntil：
http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeUntil(rx.functions.Func1)