【发布时间】:2017-02-01 11:59:52
【问题描述】:
我有一个从元素开始发出项目的流。我知道哪个元素是。一旦该元素被发射,流就不会发射更多。问题是它没有发出onComplete。我需要一些不太像takeWhile 的东西,但也需要最后一个元素。这是弹珠的想法:
(原图提取自ReactiveX TakeWhile)
我可以使用哪些运算符或多个运算符来执行此操作?
【问题讨论】:
-
好的,谢谢!我在its ReactiveX page 上看到了那个操作符,但是当我看到主实现中的两个流时,我就关闭了它。