RxJava: Объединенные наблюдаемые вызовы onComplete spuriously

Question

У меня есть несколько observervables, которые я сливаю из набора. По какой-то причине объединенный наблюдаемый вызывает onComplete, хотя отдельных наблюдаемых нет.

Пример:

Set<Observable<InputOutputEvent>> set = new HashSet<Observable<InputOutputEvent>>(); 
    for (Observable ob : obs) { 
     ob.subscribe((e) -> { 
     }, 
     (error) -> { 
System.out.println("This does NOT happen."); 
     }, 
     () -> { 
      System.out.println("This does NOT happen."); 
     }); 
     set.add(c.event()); 
    } 

    Subscription s = Observable.merge(set).subscribe((e) -> { 
      }, 
      (error) -> { 
       System.out.println("This does NOT happen."); 
      }, 
      () -> { 
       System.out.println("This DOES happen."); 
      }); 

Как это возможно? Предполагается ли, что наблюдаемое слияние не только вызывает onComplete, когда все объединенные называют это?

Я также проверял ошибки, но их нет.

Answer 1

Оставляя это как предостережение другим:

set наблюдаемых пустовала. onComplete был вызван немедленно в этом случае.