重新连接可观察的

Question

当我取消订阅可连接的观察值并在稍后再次连接时，可能会发生这种情况。

例如：

var interval = Rx.Observable.interval(1000); 

var source = interval 
    .take(2) 
    .do(function (x) { 
     console.log('Side effect'); 
    }); 

var published = source.publish(); 

published.subscribe(createObserver('SourceA')); 
published.subscribe(createObserver('SourceB')); 

// Connect the source 
var connection = published.connect(); 

function createObserver(tag) { 
    return Rx.Observer.create(
     function (x) { 
      console.log('Next: ' + tag + x); 
     }, 
     function (err) { 
      console.log('Error: ' + err); 
     }, 
     function() { 
      console.log('Completed'); 
     }); 
} 

Answer 1

是的。这正是运营商refCount()所做的。它订阅并取消订阅ConnectableObservable。

请参阅：https://github.com/ReactiveX/rxjs/blob/master/src/observable/ConnectableObservable.ts