RxJava takeUntil 与最后一项的排放? [英] RxJava takeUntil with emmision of last item?

问题描述

是否有可能在 takeUntil 运算符中发出满足条件的项目?

Is there a possibility to emit item that meets condition in takeUntil operator?

推荐答案

嗯，不确定我是否理解您的问题.像这样吗?

Mmmm not sure if I understand your question. Something like this?

@Test
public void tesTakeUntil() {
    List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
    Observable.from(numbers)
              .takeUntil(number -> number > 3)
              .subscribe(System.out::println);

}

它会打印

 1
 2
 3
 4

您可以在此处查看更多示例 https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/filtering/ObservableTake.java

You can see more examples of Take here https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/filtering/ObservableTake.java

这篇关于RxJava takeUntil 与最后一项的排放?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！