ちょっと面白かったのでメモ。 例えば複数のSubscriberを並行して処理したいなと思った時に、autoConnectで流すタイミングを合わせたとする。 Observable<Integer> foo = Observable.just(3, 4, 5).publish().autoConnect(2); foo.subscribe(data -> System.out.print</integer>…