私は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("!");
}