複数の呼び出しに関するIConnectableObservable.Connectの契約

Question

複数回呼び出されたときにIConnectableObservable.Connectの契約とは何ですか？

返されたIDisposableは、OnCompletedを公開するか、接続を切断してConnectをもう一度呼び出すことを許可する必要がありますか？

第が廃棄される前に接続が、それは、第二の時間べきで呼び出された場合：

• スロー
• おそらくコード
• リターンの異なる領域からの予期しない処分を有する戻り同じIDisposableを、何らかの種類のDispose参照カウントを持つ新しいIDisposableと呼び出し元の問題を引き起こします。まだ公開値を廃棄します。

私は実装しようとしていますIConnectableObservableとそれを実装する人々のためのドキュメントは本当に軽いです。

Answer 1

あなたはsource

（書き込みのように）あなたの最初の質問への答えを見ている場合：IDisposableインターが戻ったとき

をOnCompleted公表しなければならないのに配置されているか、それだけで切断する必要がありConnectをもう一度呼び出すことができますか？最初は

処分される前に、接続が二度目に呼び出された場合

ちょうど

を切断それはする必要があります。同じIDisposableを、おそらくの異なる領域からの予期しない処分を有する戻りますコード

後書きのための興味深いコードのセクションは次のとおりです。

 public void Dispose() 
     { 
      lock (_parent._gate) 
      { 
       if (_subscription != null) 
       { 
        _subscription.Dispose(); 
        _subscription = null; 

        _parent._connection = null; 
       } 
      } 
     } 

と

public IDisposable Connect() 
    { 
     lock (_gate) 
     { 
      if (_connection == null) 
      { 
       var subscription = _source.SubscribeSafe(_subject); 
       _connection = new Connection(this, subscription); 
      } 

      return _connection; 
     } 
    } 

あなたが上記でわかるように同時変更を防止するロックブロック内に配置され、接続されている単一の接続があります。