2
요소 이후에 항목을 방출하는 스트림이 있습니다. 나는 어떤 요소가 있는지 압니다. 해당 요소가 방출되면 스트림은 더 방출되지 않습니다. 문제는 onComplete를 방출하지 않는다는 것입니다. takeWhile
처럼 더 적은 것을 필요로하지만 마지막 요소도 emmiting합니다.takewhile을 사용하여 마지막 요소를 내보내는 방법?
(ReactiveX TakeWhile에서 추출 된 원본 이미지) 나는이 작업을 수행하는 데 사용할 수있는
어느 된 운영자 :이 구슬과 아이디어인가?
http://reactivex.io/RxJava/javadoc/rx/Observable.html#takeUntil(rx.functions.Func1)
당신이 의미 : 운영자가
Func1<T, Boolean>
조건 매개 변수takeUntil
라고: – akarnokd
네, 감사합니다! 나는 [해당 ReactiveX 페이지] (http://reactivex.io/documentation/operators/takeuntil.html)에서 해당 운영자를 보았지만 주요 구현에서 두 스트림을 보자 마자 그것을 닫았습니다. –