【问题标题】:How to emmit the last element ussing takeWhile?如何使用 takeWhile 发出最后一个元素?
【发布时间】:2017-02-01 11:59:52
【问题描述】:

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

(原图提取自ReactiveX TakeWhile

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

【问题讨论】:

标签: rx-java reactivex


【解决方案1】:

只是重复我的评论:

该运算符称为takeUntil,带有Func1<T, Boolean> 谓词参数:

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

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2017-11-22
    • 1970-01-01
    • 2021-04-08
    • 2013-04-11
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2017-11-28
    相关资源
    最近更新 更多