RxJava2: onComplete pas appelé avec flatMapIterable

Question

Voici court extrait de code:

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

Pourquoi onComplete ne pas appeler ici? Qu'est-ce que je devrais faire pour travailler ce code? Parce que dans le code d'origine, je ne peux pas utiliser la méthode .toList().

Answer 1

Le BehaviorSubject que vous avez sous sa forme est une source infinie, sauf si onComplete y est appelée. Par conséquent flatMapIterable ne se terminera pas et votre gestionnaire onComplete ne sera jamais appelé.

Donc, soit vous remplissez le 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() // <----------------------------------------------------- 

ou vous prenez au plus un élément de celui-ci

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