RxJava2：不是的onComplete与所谓flatMapIterable

Question

这里是代码一小段：

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") } 
      ) 

为什么onComplete没有不叫吗？我应该怎么做这个代码？因为在原始代码中我不能使用.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() // <----------------------------------------------------- 

，或者你

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") } 
     )