RxJava：観測可能な呼び出しをonCompleteに偽装しました

Question

私はいくつかのオブザーバビリティをセットからマージします。何らかの理由で、マージされたオブザーバブルは、個々のオブザーバブルがオンではないにもかかわらず、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がすぐに呼び出されました。