RxJava2：onCompleteのここflatMapIterable

Question

で呼び出されていないが、コードの短い抜粋ですか？私はこのコードを作業するために何をすべきですか？元のコードでは.toList()メソッドを使用できません。

Answer 1

BehaviorSubjectフォームには、onCompleteが呼び出されていない限り、無限のソースがあります。従ってflatMapIterableは完了せず、あなたのonCompleteハンドラは呼び出されません。

だから、どちらかあなたはBehaviorSubjectを完了します。

val subject = BehaviorSubject.createDefault(emptyList<Int>()) 
subject.onNext(Arrays.asList(1, 2, 3)) 
subject.flatMapIterable { list: List<Int> -> list } 
     .subscribeBy(
       onNext = { l("on next", it) }, 
       onComplete = { l("on complete") } 
     ) 

subject.onComplete() // <----------------------------------------------------- 

またはあなたがそれの最大1つのアイテム

val subject = BehaviorSubject.createDefault(emptyList<Int>()) 
subject.onNext(Arrays.asList(1, 2, 3)) 
subject.take(1) // <---------------------------------------------------------- 
     .flatMapIterable { list: List<Int> -> list } 
     .subscribeBy(
       onNext = { l("on next", it) }, 
       onComplete = { l("on complete") } 
     )