RxJava:合并的可观察对象错误地调用onComplete



我从一个集合中合并了几个观察者。由于某些原因,合并后的可观察对象调用了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当所有合并的调用它?

我也检查了错误,但是没有。

留待他人注意:

set为EMPTY。

相关内容

  • 没有找到相关文章

最新更新