Sha256: 042ea88d4b7aac1497c6e4eca1be7754a6d176f4af76d2f8494bd34139b260f1
Contents?: true
Size: 808 Bytes
Versions: 14
Compression:
Stored size: 808 Bytes
Contents
/**
* Returns an observable sequence that shares a single subscription to the underlying sequence. This observable sequence
* can be resubscribed to, even if all prior subscriptions have ended. (unlike `.publish().refCount()`)
* @returns {Observable} An observable sequence that contains the elements of a sequence produced by multicasting the source.
*/
observableProto.singleInstance = function() {
var source = this, hasObservable = false, observable;
function getObservable() {
if (!hasObservable) {
hasObservable = true;
observable = source.finally(function() { hasObservable = false; }).publish().refCount();
}
return observable;
};
return new AnonymousObservable(function(o) {
return getObservable().subscribe(o);
});
};
Version data entries
14 entries across 7 versions & 1 rubygems