0

私はreactiveX Zipでいくつかの実験を行っていましたが、zip内で定義したオブザーバブルが次々と順番に実行されることに気付きました。zip の良い点は、zip 内で定義されたすべてのオブザーバブルが 1 つのスレッドで実行されるため、すべてが並列に実行されることだと思いました。私が望むものを達成する方法はありますか?. これが私のzipの例です

         @Test
public void testZip() {
    Observable.zip(obString(), obString1(), obString2(), (s, s2, s3) -> s.concat(s2)
                                                                     .concat(s3))
              .subscribe(System.out::println);
}

public Observable<String> obString() {
    System.out.println(Thread.currentThread().getId());
    return Observable.just("hello");
}

public Observable<String> obString1() {
    System.out.println(Thread.currentThread().getId());
    return Observable.just(" world");
}

public Observable<String> obString2() {
    System.out.println(Thread.currentThread().getId());
    return Observable.just("!");
}
4

1 に答える 1