java - RxJava : Merged observable calls onComplete spuriously

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

将此作为对其他人的警告:

可观察量的集为空。在这种情况下，onComplete 被立即调用。