Wiederverbinden eines Observablen

Question

Es ist möglich, wenn ich ein verbindbares Observable abmelden und zu einem späteren Zeitpunkt wieder verbinden würde.

Zum Beispiel:

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

Ja, es ist. Genau das tut der Operator refCount(). Es abonniert und kündigt ein ConnectableObservable an.

Siehe: https://github.com/ReactiveX/rxjs/blob/master/src/observable/ConnectableObservable.ts