Sha256: c47ed27a58d3ec0a4fda1909b8070f01ec3b4314049a670101ad3b39f51c227c
Contents?: true
Size: 823 Bytes
Versions: 14
Compression:
Stored size: 823 Bytes
Contents
/**
* Returns the values from the source observable sequence until the other observable sequence produces a value.
* @param {Observable | Promise} other Observable sequence or Promise that terminates propagation of elements of the source sequence.
* @returns {Observable} An observable sequence containing the elements of the source sequence up to the point the other sequence interrupted further propagation.
*/
observableProto.takeUntil = function (other) {
var source = this;
return new AnonymousObservable(function (o) {
isPromise(other) && (other = observableFromPromise(other));
return new CompositeDisposable(
source.subscribe(o),
other.subscribe(function () { o.onCompleted(); }, function (e) { o.onError(e); }, noop)
);
}, source);
};
Version data entries
14 entries across 7 versions & 1 rubygems