RxJava2 doOnSubscribeが混乱した順序で実行されるのはなぜですか？

Question

下流上流にサブスクライブする前にdoOnSubscribeを呼び出すために、コード印刷1、RxJava1、2つのコードの印刷の両方において2

Observable.just(1) 
    .doOnSubscribe(d -> System.out.println(1)) 
    .doOnSubscribe(d -> System.out.println(2)) 
    .blockingSubscribe(); 

そして、この印刷2,1

Observable.just(1) 
    .doOnSubscribe(d -> System.out.println(1)) 
    .subscribeOn(Schedulers.newThread()) 
    .doOnSubscribe(d -> System.out.println(2)) 
    .blockingSubscribe(); 

"2,1" を後。

RxJava2では、サブスクリプションの前にアップストリームからダウンストリーム（Observer.onSubscribe）のサブスクリプションが発生しますが、まだdoOnSubscribeが呼び出されています。だから混乱した命令が発生した。

でも、私はもっと混乱し、状況与えることができます：私が期待したが、ほとんどのは期待できないとして、それは "3、4、1、2を" 印刷

Observable.just(1) 
    .doOnSubscribe(d -> System.out.println(1)) 
    .doOnSubscribe(d -> System.out.println(2)) 
    .subscribeOn(Schedulers.newThread()) 
    .doOnSubscribe(d -> System.out.println(3)) 
    .doOnSubscribe(d -> System.out.println(4)) 
    .blockingSubscribe(); 

を。

この動作は仕様ですか？はいの場合、どのようなメリットがありますか？タイムアウト前に高価な準備をしている非同期ソースを考える -

Answer 1

subscribeOnは、指定されたスレッドではなく取り消しをサポートするためにチェーンを新たに購読を開始し、それは最初に早い段階でキャンセルすることができDisposableでonSubscribeを呼び出す必要がありますそれはonSubscribeを呼び出します。理論的には、3、4、1、2の間であらゆる種類のインタリーブを得ることも可能です。