针对多次调用的IConnectableObservable.Connect合同

Question

当多次调用IConnectableObservable.Connect时，合同应该是什么？

如果返回的IDisposable被丢弃，应该发布OnCompleted还是应该断开连接并允许第二次调用Connect？

如果之前所述第一布置的连接被称为第二时间，应该它：

• 掷
• 返回相同的IDisposable，可能具有的代码
• 返回不同区域意想不到的处置一个新的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; 
     } 
    } 

正如你可以看到在上面有被布置和锁定块内连接到以防止并发修改的单个连接。