`ReplaySubject`を購読中にクロージャを実行させることは可能ですか？

Question

私は実際のサブスクリプションがある場合にのみ高価な操作を開始するだろうコールドオブザーバブルを作成したいと思います。 ReplaySubjectは、実際のサブスクリプションが行われたときに高価なバックグラウンド操作を開始できる必要があり、オブザーバブルの作成時には必要でない部分を除いてうまく収まります。そうする方法はありますか？いくつかの種類のonSubscribed { ... }メソッド。

let observable = Observable.of(1, 2) 
    .doOn(onSubscribe: { _ in 
     expensiveOperation() 
    }) 

observable 
    .subscribeNext { e in 
     print(e) 
    } 

Observable接続を作成し、doOn(onSubscribe:)分離：

を Observableおよびサブスクリプションの間でだ doOn(onSubscribe:)に高価な操作を追加

：ここ

Answer 1

は、オプションのカップルです

let observable = Observable.of(1, 2) 
    .publish() 

observable 
    .doOn(onSubscribe: { _ in 
     expensiveOperation() 
    }) 
    .subscribe() 

observable 
    .subscribeNext { e in 
     print(e) 
    } 

observable.connect()