它是如何工作的。mergeDelayError（）之后的take（）？

Question

我有一些这样的代码：

    Set<Something> set = HashSet<>();
    // [...]
    return Observable.mergeDelayError(
            Observable.from(set)
                    .map(something -> process(something)))
            .take(1);

根据文件：

mergeDelayError：将发出可观测值的可观测值展平为一个可观测值，使观察者能够从所有源可观测值接收所有成功发出的项目，而不会被其中一个可观测值的错误通知打断。

到目前为止，我理解。我的问题是关于take（）方法：它会等待所有可观察对象返回某个结果，然后再获取第一个结果，还是从第一个完成的可观察对象获取第一个结果？

TIA，

Answer 1

它是否会等待所有可观察到的结果返回某个值，然后再获取第一个结果

这是正确的

UPD公司

根据该测试，它返回第一个发出的项目

    Observable.mergeDelayError(
            Observable.just(null)
                    .doOnNext(x -> {
                        throw new RuntimeException();
                    }),
            Observable.just(1).delay(70, TimeUnit.MILLISECONDS),
            Observable.just(2).delay(50, TimeUnit.MILLISECONDS))
            .take(1)
            .subscribe(System.out::print);