Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

rx

Package Overview
Dependencies
Maintainers
2
Versions
103
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

rx - npm Package Compare versions

Comparing version 4.0.6 to 4.0.7

ts/core/linq/observable/mergeconcat.ts

2

dist/rx.async.compat.js

@@ -201,3 +201,3 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

function isGenerator(obj) {
return isFunction (obj.next) && isFunction (obj.throw);
return isFunction (obj.next) && isFunction (obj['throw']);
}

@@ -204,0 +204,0 @@

2

dist/rx.async.js

@@ -201,3 +201,3 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

function isGenerator(obj) {
return isFunction (obj.next) && isFunction (obj.throw);
return isFunction (obj.next) && isFunction (obj['throw']);
}

@@ -204,0 +204,0 @@

4

dist/rx.backpressure.js

@@ -281,4 +281,4 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

*/
observableProto.pausableBuffered = function (subject) {
return new PausableBufferedObservable(this, subject);
observableProto.pausableBuffered = function (pauser) {
return new PausableBufferedObservable(this, pauser);
};

@@ -285,0 +285,0 @@

41

dist/rx.binding.js

@@ -263,7 +263,5 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

getValue: function () {
checkDisposed(this);
if (this.hasError) {
throw this.error;
}
return this.value;
checkDisposed(this);
if (this.hasError) { thrower(this.error); }
return this.value;
},

@@ -477,4 +475,4 @@ /**

RefCountObservable.prototype.subscribeCore = function (o) {
var shouldConnect = ++this._count === 1, subscription = this.source.subscribe(o);
shouldConnect && (this._connectableSubscription = this.source.connect());
var subscription = this.source.subscribe(o);
++this._count === 1 && (this._connectableSubscription = this.source.connect());
return new RefCountDisposable(this, subscription);

@@ -504,5 +502,4 @@ };

this.source = source;
this._hasSubscription = false;
this._subscription = null;
this._sourceObservable = source.asObservable();
this._connection = null;
this._source = source.asObservable();
this._subject = subject;

@@ -512,11 +509,12 @@ __super__.call(this);

function ConnectDisposable(parent) {
function ConnectDisposable(parent, subscription) {
this._p = parent;
this.isDisposed = false;
this._s = subscription;
}
ConnectDisposable.prototype.dispose = function () {
if (!this.isDisposed) {
this.isDisposed = true;
this._p._hasSubscription = false;
if (this._s) {
this._s.dispose();
this._s = null;
this._p._connection = null;
}

@@ -526,10 +524,7 @@ };

ConnectableObservable.prototype.connect = function () {
if (!this._hasSubscription) {
this._hasSubscription = true;
this._subscription = new BinaryDisposable(
this._sourceObservable.subscribe(this._subject),
new ConnectDisposable(this)
);
if (!this._connection) {
var subscription = this._source.subscribe(this._subject);
this._connection = new ConnectDisposable(this, subscription);
}
return this._subscription;
return this._connection;
};

@@ -559,3 +554,3 @@

hasObservable = true;
observable = source.finally(function() { hasObservable = false; }).publish().refCount();
observable = source['finally'](function() { hasObservable = false; }).publish().refCount();
}

@@ -562,0 +557,0 @@ return observable;

2

dist/rx.binding.min.js
/* Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.*/
(function(a){function b(a){return a&&a.Object===Object?a:null}var c={"function":!0,object:!0},d=c[typeof exports]&&exports&&!exports.nodeType?exports:null,e=c[typeof module]&&module&&!module.nodeType?module:null,f=b(d&&e&&"object"==typeof global&&global),g=b(c[typeof self]&&self),h=b(c[typeof window]&&window),i=(e&&e.exports===d?d:null,b(c[typeof this]&&this)),j=f||h!==(i&&i.window)&&h||g||i||Function("return this")();"function"==typeof define&&define.amd?define(["./rx"],function(b,c){return a(j,c,b)}):"object"==typeof module&&module&&module.exports===d?module.exports=a(j,module.exports,require("./rx")):j.Rx=a(j,{},j.Rx)}).call(this,function(a,b,c,d){function e(a){for(var b=a.length,c=new Array(b),d=0;b>d;d++)c[d]=a[d];return c}var f=c.Observable,g=f.prototype,h=c.AnonymousObservable,i=c.ObservableBase,j=c.Subject,k=c.AsyncSubject,l=c.Observer,m=c.internals.ScheduledObserver,n=c.Disposable.create,o=c.Disposable.empty,p=c.BinaryDisposable,q=c.Scheduler.currentThread,r=c.helpers.isFunction,s=c.internals.inherits,t=c.internals.addProperties,u=c.Disposable.checkDisposed,v=function(a){function b(b,c,d){this.source=b,this._fn1=c,this._fn2=d,a.call(this)}return s(b,a),b.prototype.subscribeCore=function(a){var b=this.source.multicast(this._fn1());return new p(this._fn2(b).subscribe(a),b.connect())},b}(i);g.multicast=function(a,b){return r(a)?new v(this,a,b):new A(this,a)},g.publish=function(a){return a&&r(a)?this.multicast(function(){return new j},a):this.multicast(new j)},g.share=function(){return this.publish().refCount()},g.publishLast=function(a){return a&&r(a)?this.multicast(function(){return new k},a):this.multicast(new k)},g.publishValue=function(a,b){return 2===arguments.length?this.multicast(function(){return new x(b)},a):this.multicast(new x(a))},g.shareValue=function(a){return this.publishValue(a).refCount()},g.replay=function(a,b,c,d){return a&&r(a)?this.multicast(function(){return new y(b,c,d)},a):this.multicast(new y(b,c,d))},g.shareReplay=function(a,b,c){return this.replay(null,a,b,c).refCount()};var w=function(a,b){this._s=a,this._o=b};w.prototype.dispose=function(){if(!this._s.isDisposed&&null!==this._o){var a=this._s.observers.indexOf(this._o);this._s.observers.splice(a,1),this._o=null}};var x=c.BehaviorSubject=function(a){function b(b){a.call(this),this.value=b,this.observers=[],this.isDisposed=!1,this.isStopped=!1,this.hasError=!1}return s(b,a),t(b.prototype,l.prototype,{_subscribe:function(a){return u(this),this.isStopped?(this.hasError?a.onError(this.error):a.onCompleted(),o):(this.observers.push(a),a.onNext(this.value),new w(this,a))},getValue:function(){if(u(this),this.hasError)throw this.error;return this.value},hasObservers:function(){return this.observers.length>0},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;for(var a=0,b=e(this.observers),c=b.length;c>a;a++)b[a].onCompleted();this.observers.length=0}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.hasError=!0,this.error=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onError(a);this.observers.length=0}},onNext:function(a){if(u(this),!this.isStopped){this.value=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onNext(a)}},dispose:function(){this.isDisposed=!0,this.observers=null,this.value=null,this.error=null}}),b}(f),y=c.ReplaySubject=function(a){function b(a,b){return n(function(){b.dispose(),!a.isDisposed&&a.observers.splice(a.observers.indexOf(b),1)})}function c(b,c,e){this.bufferSize=null==b?d:b,this.windowSize=null==c?d:c,this.scheduler=e||q,this.q=[],this.observers=[],this.isStopped=!1,this.isDisposed=!1,this.hasError=!1,this.error=null,a.call(this)}var d=Math.pow(2,53)-1;return s(c,a),t(c.prototype,l.prototype,{_subscribe:function(a){u(this);var c=new m(this.scheduler,a),d=b(this,c);this._trim(this.scheduler.now()),this.observers.push(c);for(var e=0,f=this.q.length;f>e;e++)c.onNext(this.q[e].value);return this.hasError?c.onError(this.error):this.isStopped&&c.onCompleted(),c.ensureActive(),d},hasObservers:function(){return this.observers.length>0},_trim:function(a){for(;this.q.length>this.bufferSize;)this.q.shift();for(;this.q.length>0&&a-this.q[0].interval>this.windowSize;)this.q.shift()},onNext:function(a){if(u(this),!this.isStopped){var b=this.scheduler.now();this.q.push({interval:b,value:a}),this._trim(b);for(var c=0,d=e(this.observers),f=d.length;f>c;c++){var g=d[c];g.onNext(a),g.ensureActive()}}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.error=a,this.hasError=!0;var b=this.scheduler.now();this._trim(b);for(var c=0,d=e(this.observers),f=d.length;f>c;c++){var g=d[c];g.onError(a),g.ensureActive()}this.observers.length=0}},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;var a=this.scheduler.now();this._trim(a);for(var b=0,c=e(this.observers),d=c.length;d>b;b++){var f=c[b];f.onCompleted(),f.ensureActive()}this.observers.length=0}},dispose:function(){this.isDisposed=!0,this.observers=null}}),c}(f),z=function(a){function b(b){this.source=b,this._count=0,this._connectableSubscription=null,a.call(this)}function c(a,b){this._p=a,this._s=b,this.isDisposed=!1}return s(b,a),b.prototype.subscribeCore=function(a){var b=1===++this._count,d=this.source.subscribe(a);return b&&(this._connectableSubscription=this.source.connect()),new c(this,d)},c.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,this._s.dispose(),0===--this._p._count&&this._p._connectableSubscription.dispose())},b}(i),A=c.ConnectableObservable=function(a){function b(b,c){this.source=b,this._hasSubscription=!1,this._subscription=null,this._sourceObservable=b.asObservable(),this._subject=c,a.call(this)}function c(a){this._p=a,this.isDisposed=!1}return s(b,a),c.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,this._p._hasSubscription=!1)},b.prototype.connect=function(){return this._hasSubscription||(this._hasSubscription=!0,this._subscription=new p(this._sourceObservable.subscribe(this._subject),new c(this))),this._subscription},b.prototype._subscribe=function(a){return this._subject.subscribe(a)},b.prototype.refCount=function(){return new z(this)},b}(f);return g.singleInstance=function(){function a(){return d||(d=!0,b=c["finally"](function(){d=!1}).publish().refCount()),b}var b,c=this,d=!1;return new h(function(b){return a().subscribe(b)})},c});
(function(a){function b(a){return a&&a.Object===Object?a:null}var c={"function":!0,object:!0},d=c[typeof exports]&&exports&&!exports.nodeType?exports:null,e=c[typeof module]&&module&&!module.nodeType?module:null,f=b(d&&e&&"object"==typeof global&&global),g=b(c[typeof self]&&self),h=b(c[typeof window]&&window),i=(e&&e.exports===d?d:null,b(c[typeof this]&&this)),j=f||h!==(i&&i.window)&&h||g||i||Function("return this")();"function"==typeof define&&define.amd?define(["./rx"],function(b,c){return a(j,c,b)}):"object"==typeof module&&module&&module.exports===d?module.exports=a(j,module.exports,require("./rx")):j.Rx=a(j,{},j.Rx)}).call(this,function(a,b,c,d){function e(a){for(var b=a.length,c=new Array(b),d=0;b>d;d++)c[d]=a[d];return c}var f=c.Observable,g=f.prototype,h=c.AnonymousObservable,i=c.ObservableBase,j=c.Subject,k=c.AsyncSubject,l=c.Observer,m=c.internals.ScheduledObserver,n=c.Disposable.create,o=c.Disposable.empty,p=c.BinaryDisposable,q=c.Scheduler.currentThread,r=c.helpers.isFunction,s=c.internals.inherits,t=c.internals.addProperties,u=c.Disposable.checkDisposed,v=function(a){function b(b,c,d){this.source=b,this._fn1=c,this._fn2=d,a.call(this)}return s(b,a),b.prototype.subscribeCore=function(a){var b=this.source.multicast(this._fn1());return new p(this._fn2(b).subscribe(a),b.connect())},b}(i);g.multicast=function(a,b){return r(a)?new v(this,a,b):new A(this,a)},g.publish=function(a){return a&&r(a)?this.multicast(function(){return new j},a):this.multicast(new j)},g.share=function(){return this.publish().refCount()},g.publishLast=function(a){return a&&r(a)?this.multicast(function(){return new k},a):this.multicast(new k)},g.publishValue=function(a,b){return 2===arguments.length?this.multicast(function(){return new x(b)},a):this.multicast(new x(a))},g.shareValue=function(a){return this.publishValue(a).refCount()},g.replay=function(a,b,c,d){return a&&r(a)?this.multicast(function(){return new y(b,c,d)},a):this.multicast(new y(b,c,d))},g.shareReplay=function(a,b,c){return this.replay(null,a,b,c).refCount()};var w=function(a,b){this._s=a,this._o=b};w.prototype.dispose=function(){if(!this._s.isDisposed&&null!==this._o){var a=this._s.observers.indexOf(this._o);this._s.observers.splice(a,1),this._o=null}};var x=c.BehaviorSubject=function(a){function b(b){a.call(this),this.value=b,this.observers=[],this.isDisposed=!1,this.isStopped=!1,this.hasError=!1}return s(b,a),t(b.prototype,l.prototype,{_subscribe:function(a){return u(this),this.isStopped?(this.hasError?a.onError(this.error):a.onCompleted(),o):(this.observers.push(a),a.onNext(this.value),new w(this,a))},getValue:function(){return u(this),this.hasError&&thrower(this.error),this.value},hasObservers:function(){return this.observers.length>0},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;for(var a=0,b=e(this.observers),c=b.length;c>a;a++)b[a].onCompleted();this.observers.length=0}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.hasError=!0,this.error=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onError(a);this.observers.length=0}},onNext:function(a){if(u(this),!this.isStopped){this.value=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onNext(a)}},dispose:function(){this.isDisposed=!0,this.observers=null,this.value=null,this.error=null}}),b}(f),y=c.ReplaySubject=function(a){function b(a,b){return n(function(){b.dispose(),!a.isDisposed&&a.observers.splice(a.observers.indexOf(b),1)})}function c(b,c,e){this.bufferSize=null==b?d:b,this.windowSize=null==c?d:c,this.scheduler=e||q,this.q=[],this.observers=[],this.isStopped=!1,this.isDisposed=!1,this.hasError=!1,this.error=null,a.call(this)}var d=Math.pow(2,53)-1;return s(c,a),t(c.prototype,l.prototype,{_subscribe:function(a){u(this);var c=new m(this.scheduler,a),d=b(this,c);this._trim(this.scheduler.now()),this.observers.push(c);for(var e=0,f=this.q.length;f>e;e++)c.onNext(this.q[e].value);return this.hasError?c.onError(this.error):this.isStopped&&c.onCompleted(),c.ensureActive(),d},hasObservers:function(){return this.observers.length>0},_trim:function(a){for(;this.q.length>this.bufferSize;)this.q.shift();for(;this.q.length>0&&a-this.q[0].interval>this.windowSize;)this.q.shift()},onNext:function(a){if(u(this),!this.isStopped){var b=this.scheduler.now();this.q.push({interval:b,value:a}),this._trim(b);for(var c=0,d=e(this.observers),f=d.length;f>c;c++){var g=d[c];g.onNext(a),g.ensureActive()}}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.error=a,this.hasError=!0;var b=this.scheduler.now();this._trim(b);for(var c=0,d=e(this.observers),f=d.length;f>c;c++){var g=d[c];g.onError(a),g.ensureActive()}this.observers.length=0}},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;var a=this.scheduler.now();this._trim(a);for(var b=0,c=e(this.observers),d=c.length;d>b;b++){var f=c[b];f.onCompleted(),f.ensureActive()}this.observers.length=0}},dispose:function(){this.isDisposed=!0,this.observers=null}}),c}(f),z=function(a){function b(b){this.source=b,this._count=0,this._connectableSubscription=null,a.call(this)}function c(a,b){this._p=a,this._s=b,this.isDisposed=!1}return s(b,a),b.prototype.subscribeCore=function(a){var b=this.source.subscribe(a);return 1===++this._count&&(this._connectableSubscription=this.source.connect()),new c(this,b)},c.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,this._s.dispose(),0===--this._p._count&&this._p._connectableSubscription.dispose())},b}(i),A=c.ConnectableObservable=function(a){function b(b,c){this.source=b,this._connection=null,this._source=b.asObservable(),this._subject=c,a.call(this)}function c(a,b){this._p=a,this._s=b}return s(b,a),c.prototype.dispose=function(){this._s&&(this._s.dispose(),this._s=null,this._p._connection=null)},b.prototype.connect=function(){if(!this._connection){var a=this._source.subscribe(this._subject);this._connection=new c(this,a)}return this._connection},b.prototype._subscribe=function(a){return this._subject.subscribe(a)},b.prototype.refCount=function(){return new z(this)},b}(f);return g.singleInstance=function(){function a(){return d||(d=!0,b=c["finally"](function(){d=!1}).publish().refCount()),b}var b,c=this,d=!1;return new h(function(b){return a().subscribe(b)})},c});
//# sourceMappingURL=rx.binding.map

92

dist/rx.core.binding.js

@@ -247,17 +247,36 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

ScheduledObserver.prototype.next = function (value) {
var self = this;
this.queue.push(function () { self.observer.onNext(value); });
function enqueueNext(observer, x) { return function () { observer.onNext(x); }; }
function enqueueError(observer, e) { return function () { observer.onError(e); }; }
function enqueueCompleted(observer) { return function () { observer.onCompleted(); }; }
ScheduledObserver.prototype.next = function (x) {
this.queue.push(enqueueNext(this.observer, x));
};
ScheduledObserver.prototype.error = function (e) {
var self = this;
this.queue.push(function () { self.observer.onError(e); });
this.queue.push(enqueueError(this.observer, e));
};
ScheduledObserver.prototype.completed = function () {
var self = this;
this.queue.push(function () { self.observer.onCompleted(); });
this.queue.push(enqueueCompleted(this.observer));
};
function scheduleMethod(state, recurse) {
var work;
if (state.queue.length > 0) {
work = state.queue.shift();
} else {
state.isAcquired = false;
return;
}
var res = tryCatch(work)();
if (res === errorObj) {
state.queue = [];
state.hasFaulted = true;
return thrower(res.e);
}
recurse(state);
}
ScheduledObserver.prototype.ensureActive = function () {

@@ -269,20 +288,4 @@ var isOwner = false;

}
if (isOwner) {
this.disposable.setDisposable(this.scheduler.scheduleRecursive(this, function (parent, self) {
var work;
if (parent.queue.length > 0) {
work = parent.queue.shift();
} else {
parent.isAcquired = false;
return;
}
var res = tryCatch(work)();
if (res === errorObj) {
parent.queue = [];
parent.hasFaulted = true;
return thrower(res.e);
}
self(parent);
}));
}
isOwner &&
this.disposable.setDisposable(this.scheduler.scheduleRecursive(this, scheduleMethod));
};

@@ -588,7 +591,5 @@

getValue: function () {
checkDisposed(this);
if (this.hasError) {
throw this.error;
}
return this.value;
checkDisposed(this);
if (this.hasError) { thrower(this.error); }
return this.value;
},

@@ -802,4 +803,4 @@ /**

RefCountObservable.prototype.subscribeCore = function (o) {
var shouldConnect = ++this._count === 1, subscription = this.source.subscribe(o);
shouldConnect && (this._connectableSubscription = this.source.connect());
var subscription = this.source.subscribe(o);
++this._count === 1 && (this._connectableSubscription = this.source.connect());
return new RefCountDisposable(this, subscription);

@@ -829,5 +830,4 @@ };

this.source = source;
this._hasSubscription = false;
this._subscription = null;
this._sourceObservable = source.asObservable();
this._connection = null;
this._source = source.asObservable();
this._subject = subject;

@@ -837,11 +837,12 @@ __super__.call(this);

function ConnectDisposable(parent) {
function ConnectDisposable(parent, subscription) {
this._p = parent;
this.isDisposed = false;
this._s = subscription;
}
ConnectDisposable.prototype.dispose = function () {
if (!this.isDisposed) {
this.isDisposed = true;
this._p._hasSubscription = false;
if (this._s) {
this._s.dispose();
this._s = null;
this._p._connection = null;
}

@@ -851,10 +852,7 @@ };

ConnectableObservable.prototype.connect = function () {
if (!this._hasSubscription) {
this._hasSubscription = true;
this._subscription = new BinaryDisposable(
this._sourceObservable.subscribe(this._subject),
new ConnectDisposable(this)
);
if (!this._connection) {
var subscription = this._source.subscribe(this._subject);
this._connection = new ConnectDisposable(this, subscription);
}
return this._subscription;
return this._connection;
};

@@ -861,0 +859,0 @@

2

dist/rx.core.binding.min.js
/* Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.*/
(function(a){function b(a){return a&&a.Object===Object?a:null}var c={"function":!0,object:!0},d=c[typeof exports]&&exports&&!exports.nodeType?exports:null,e=c[typeof module]&&module&&!module.nodeType?module:null,f=b(d&&e&&"object"==typeof global&&global),g=b(c[typeof self]&&self),h=b(c[typeof window]&&window),i=(e&&e.exports===d?d:null,b(c[typeof this]&&this)),j=f||h!==(i&&i.window)&&h||g||i||Function("return this")();"function"==typeof define&&define.amd?define(["./rx.core"],function(b,c){return a(j,c,b)}):"object"==typeof module&&module&&module.exports===d?module.exports=a(j,module.exports,require("./rx.core")):j.Rx=a(j,{},j.Rx)}).call(this,function(a,b,c,d){function e(a){for(var b=a.length,c=new Array(b),d=0;b>d;d++)c[d]=a[d];return c}function f(a){return function(){try{return a.apply(this,arguments)}catch(b){return v.e=b,v}}}function g(a){throw a}var h=c.Observable,i=h.prototype,j=(c.AnonymousObservable,c.ObservableBase),k=c.Observer,l=c.internals.AbstractObserver,m=c.Disposable.create,n=c.Disposable.empty,o=(c.CompositeDisposable,c.BinaryDisposable),p=c.SerialDisposable,q=c.Scheduler.currentThread,r=c.helpers.isFunction,s=c.internals.inherits,t=c.internals.addProperties,u=c.Disposable.checkDisposed,v={e:{}},w=c.internals.tryCatch=function(a){if(!r(a))throw new TypeError("fn must be a function");return f(a)},x=function(a){function b(b,c,d){this.source=b,this._fn1=c,this._fn2=d,a.call(this)}return s(b,a),b.prototype.subscribeCore=function(a){var b=this.source.multicast(this._fn1());return new o(this._fn2(b).subscribe(a),b.connect())},b}(j);i.multicast=function(a,b){return r(a)?new x(this,a,b):new G(this,a)},i.publish=function(a){return a&&r(a)?this.multicast(function(){return new A},a):this.multicast(new A)},i.share=function(){return this.publish().refCount()},i.publishLast=function(a){return a&&r(a)?this.multicast(function(){return new C},a):this.multicast(new C)},i.publishValue=function(a,b){return 2===arguments.length?this.multicast(function(){return new D(b)},a):this.multicast(new D(a))},i.shareValue=function(a){return this.publishValue(a).refCount()},i.replay=function(a,b,c,d){return a&&r(a)?this.multicast(function(){return new E(b,c,d)},a):this.multicast(new E(b,c,d))},i.shareReplay=function(a,b,c){return this.replay(null,a,b,c).refCount()};var y=c.internals.ScheduledObserver=function(a){function b(b,c){a.call(this),this.scheduler=b,this.observer=c,this.isAcquired=!1,this.hasFaulted=!1,this.queue=[],this.disposable=new p}return s(b,a),b.prototype.next=function(a){var b=this;this.queue.push(function(){b.observer.onNext(a)})},b.prototype.error=function(a){var b=this;this.queue.push(function(){b.observer.onError(a)})},b.prototype.completed=function(){var a=this;this.queue.push(function(){a.observer.onCompleted()})},b.prototype.ensureActive=function(){var a=!1;!this.hasFaulted&&this.queue.length>0&&(a=!this.isAcquired,this.isAcquired=!0),a&&this.disposable.setDisposable(this.scheduler.scheduleRecursive(this,function(a,b){var c;if(!(a.queue.length>0))return void(a.isAcquired=!1);c=a.queue.shift();var d=w(c)();return d===v?(a.queue=[],a.hasFaulted=!0,g(d.e)):void b(a)}))},b.prototype.dispose=function(){a.prototype.dispose.call(this),this.disposable.dispose()},b}(l),z=function(a,b){this._s=a,this._o=b};z.prototype.dispose=function(){if(!this._s.isDisposed&&null!==this._o){var a=this._s.observers.indexOf(this._o);this._s.observers.splice(a,1),this._o=null}};var A=c.Subject=function(a){function b(){a.call(this),this.isDisposed=!1,this.isStopped=!1,this.observers=[],this.hasError=!1}return s(b,a),t(b.prototype,k.prototype,{_subscribe:function(a){return u(this),this.isStopped?this.hasError?(a.onError(this.error),n):(a.onCompleted(),n):(this.observers.push(a),new z(this,a))},hasObservers:function(){return this.observers.length>0},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;for(var a=0,b=e(this.observers),c=b.length;c>a;a++)b[a].onCompleted();this.observers.length=0}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.error=a,this.hasError=!0;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onError(a);this.observers.length=0}},onNext:function(a){if(u(this),!this.isStopped)for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onNext(a)},dispose:function(){this.isDisposed=!0,this.observers=null}}),b.create=function(a,b){return new B(a,b)},b}(h),B=c.AnonymousSubject=function(a){function b(b,c){this.observer=b,this.observable=c,a.call(this)}return s(b,a),t(b.prototype,k.prototype,{_subscribe:function(a){return this.observable.subscribe(a)},onCompleted:function(){this.observer.onCompleted()},onError:function(a){this.observer.onError(a)},onNext:function(a){this.observer.onNext(a)}}),b}(h),C=c.AsyncSubject=function(a){function b(){a.call(this),this.isDisposed=!1,this.isStopped=!1,this.hasValue=!1,this.observers=[],this.hasError=!1}return s(b,a),t(b.prototype,k.prototype,{_subscribe:function(a){return u(this),this.isStopped?(this.hasError?a.onError(this.error):this.hasValue?(a.onNext(this.value),a.onCompleted()):a.onCompleted(),n):(this.observers.push(a),new z(this,a))},hasObservers:function(){return u(this),this.observers.length>0},onCompleted:function(){var a,b;if(u(this),!this.isStopped){this.isStopped=!0;var c=e(this.observers),b=c.length;if(this.hasValue)for(a=0;b>a;a++){var d=c[a];d.onNext(this.value),d.onCompleted()}else for(a=0;b>a;a++)c[a].onCompleted();this.observers.length=0}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.hasError=!0,this.error=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onError(a);this.observers.length=0}},onNext:function(a){u(this),this.isStopped||(this.value=a,this.hasValue=!0)},dispose:function(){this.isDisposed=!0,this.observers=null,this.error=null,this.value=null}}),b}(h),D=c.BehaviorSubject=function(a){function b(b){a.call(this),this.value=b,this.observers=[],this.isDisposed=!1,this.isStopped=!1,this.hasError=!1}return s(b,a),t(b.prototype,k.prototype,{_subscribe:function(a){return u(this),this.isStopped?(this.hasError?a.onError(this.error):a.onCompleted(),n):(this.observers.push(a),a.onNext(this.value),new z(this,a))},getValue:function(){if(u(this),this.hasError)throw this.error;return this.value},hasObservers:function(){return this.observers.length>0},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;for(var a=0,b=e(this.observers),c=b.length;c>a;a++)b[a].onCompleted();this.observers.length=0}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.hasError=!0,this.error=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onError(a);this.observers.length=0}},onNext:function(a){if(u(this),!this.isStopped){this.value=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onNext(a)}},dispose:function(){this.isDisposed=!0,this.observers=null,this.value=null,this.error=null}}),b}(h),E=c.ReplaySubject=function(a){function b(a,b){return m(function(){b.dispose(),!a.isDisposed&&a.observers.splice(a.observers.indexOf(b),1)})}function c(b,c,e){this.bufferSize=null==b?d:b,this.windowSize=null==c?d:c,this.scheduler=e||q,this.q=[],this.observers=[],this.isStopped=!1,this.isDisposed=!1,this.hasError=!1,this.error=null,a.call(this)}var d=Math.pow(2,53)-1;return s(c,a),t(c.prototype,k.prototype,{_subscribe:function(a){u(this);var c=new y(this.scheduler,a),d=b(this,c);this._trim(this.scheduler.now()),this.observers.push(c);for(var e=0,f=this.q.length;f>e;e++)c.onNext(this.q[e].value);return this.hasError?c.onError(this.error):this.isStopped&&c.onCompleted(),c.ensureActive(),d},hasObservers:function(){return this.observers.length>0},_trim:function(a){for(;this.q.length>this.bufferSize;)this.q.shift();for(;this.q.length>0&&a-this.q[0].interval>this.windowSize;)this.q.shift()},onNext:function(a){if(u(this),!this.isStopped){var b=this.scheduler.now();this.q.push({interval:b,value:a}),this._trim(b);for(var c=0,d=e(this.observers),f=d.length;f>c;c++){var g=d[c];g.onNext(a),g.ensureActive()}}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.error=a,this.hasError=!0;var b=this.scheduler.now();this._trim(b);for(var c=0,d=e(this.observers),f=d.length;f>c;c++){var g=d[c];g.onError(a),g.ensureActive()}this.observers.length=0}},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;var a=this.scheduler.now();this._trim(a);for(var b=0,c=e(this.observers),d=c.length;d>b;b++){var f=c[b];f.onCompleted(),f.ensureActive()}this.observers.length=0}},dispose:function(){this.isDisposed=!0,this.observers=null}}),c}(h),F=function(a){function b(b){this.source=b,this._count=0,this._connectableSubscription=null,a.call(this)}function c(a,b){this._p=a,this._s=b,this.isDisposed=!1}return s(b,a),b.prototype.subscribeCore=function(a){var b=1===++this._count,d=this.source.subscribe(a);return b&&(this._connectableSubscription=this.source.connect()),new c(this,d)},c.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,this._s.dispose(),0===--this._p._count&&this._p._connectableSubscription.dispose())},b}(j),G=c.ConnectableObservable=function(a){function b(b,c){this.source=b,this._hasSubscription=!1,this._subscription=null,this._sourceObservable=b.asObservable(),this._subject=c,a.call(this)}function c(a){this._p=a,this.isDisposed=!1}return s(b,a),c.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,this._p._hasSubscription=!1)},b.prototype.connect=function(){return this._hasSubscription||(this._hasSubscription=!0,this._subscription=new o(this._sourceObservable.subscribe(this._subject),new c(this))),this._subscription},b.prototype._subscribe=function(a){return this._subject.subscribe(a)},b.prototype.refCount=function(){return new F(this)},b}(h);return c});
(function(a){function b(a){return a&&a.Object===Object?a:null}var c={"function":!0,object:!0},d=c[typeof exports]&&exports&&!exports.nodeType?exports:null,e=c[typeof module]&&module&&!module.nodeType?module:null,f=b(d&&e&&"object"==typeof global&&global),g=b(c[typeof self]&&self),h=b(c[typeof window]&&window),i=(e&&e.exports===d?d:null,b(c[typeof this]&&this)),j=f||h!==(i&&i.window)&&h||g||i||Function("return this")();"function"==typeof define&&define.amd?define(["./rx.core"],function(b,c){return a(j,c,b)}):"object"==typeof module&&module&&module.exports===d?module.exports=a(j,module.exports,require("./rx.core")):j.Rx=a(j,{},j.Rx)}).call(this,function(a,b,c,d){function e(a){for(var b=a.length,c=new Array(b),d=0;b>d;d++)c[d]=a[d];return c}function f(a){return function(){try{return a.apply(this,arguments)}catch(b){return v.e=b,v}}}function g(a){throw a}var h=c.Observable,i=h.prototype,j=(c.AnonymousObservable,c.ObservableBase),k=c.Observer,l=c.internals.AbstractObserver,m=c.Disposable.create,n=c.Disposable.empty,o=(c.CompositeDisposable,c.BinaryDisposable),p=c.SerialDisposable,q=c.Scheduler.currentThread,r=c.helpers.isFunction,s=c.internals.inherits,t=c.internals.addProperties,u=c.Disposable.checkDisposed,v={e:{}},w=c.internals.tryCatch=function(a){if(!r(a))throw new TypeError("fn must be a function");return f(a)},x=function(a){function b(b,c,d){this.source=b,this._fn1=c,this._fn2=d,a.call(this)}return s(b,a),b.prototype.subscribeCore=function(a){var b=this.source.multicast(this._fn1());return new o(this._fn2(b).subscribe(a),b.connect())},b}(j);i.multicast=function(a,b){return r(a)?new x(this,a,b):new G(this,a)},i.publish=function(a){return a&&r(a)?this.multicast(function(){return new A},a):this.multicast(new A)},i.share=function(){return this.publish().refCount()},i.publishLast=function(a){return a&&r(a)?this.multicast(function(){return new C},a):this.multicast(new C)},i.publishValue=function(a,b){return 2===arguments.length?this.multicast(function(){return new D(b)},a):this.multicast(new D(a))},i.shareValue=function(a){return this.publishValue(a).refCount()},i.replay=function(a,b,c,d){return a&&r(a)?this.multicast(function(){return new E(b,c,d)},a):this.multicast(new E(b,c,d))},i.shareReplay=function(a,b,c){return this.replay(null,a,b,c).refCount()};var y=c.internals.ScheduledObserver=function(a){function b(b,c){a.call(this),this.scheduler=b,this.observer=c,this.isAcquired=!1,this.hasFaulted=!1,this.queue=[],this.disposable=new p}function c(a,b){return function(){a.onNext(b)}}function d(a,b){return function(){a.onError(b)}}function e(a){return function(){a.onCompleted()}}function f(a,b){var c;if(!(a.queue.length>0))return void(a.isAcquired=!1);c=a.queue.shift();var d=w(c)();return d===v?(a.queue=[],a.hasFaulted=!0,g(d.e)):void b(a)}return s(b,a),b.prototype.next=function(a){this.queue.push(c(this.observer,a))},b.prototype.error=function(a){this.queue.push(d(this.observer,a))},b.prototype.completed=function(){this.queue.push(e(this.observer))},b.prototype.ensureActive=function(){var a=!1;!this.hasFaulted&&this.queue.length>0&&(a=!this.isAcquired,this.isAcquired=!0),a&&this.disposable.setDisposable(this.scheduler.scheduleRecursive(this,f))},b.prototype.dispose=function(){a.prototype.dispose.call(this),this.disposable.dispose()},b}(l),z=function(a,b){this._s=a,this._o=b};z.prototype.dispose=function(){if(!this._s.isDisposed&&null!==this._o){var a=this._s.observers.indexOf(this._o);this._s.observers.splice(a,1),this._o=null}};var A=c.Subject=function(a){function b(){a.call(this),this.isDisposed=!1,this.isStopped=!1,this.observers=[],this.hasError=!1}return s(b,a),t(b.prototype,k.prototype,{_subscribe:function(a){return u(this),this.isStopped?this.hasError?(a.onError(this.error),n):(a.onCompleted(),n):(this.observers.push(a),new z(this,a))},hasObservers:function(){return this.observers.length>0},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;for(var a=0,b=e(this.observers),c=b.length;c>a;a++)b[a].onCompleted();this.observers.length=0}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.error=a,this.hasError=!0;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onError(a);this.observers.length=0}},onNext:function(a){if(u(this),!this.isStopped)for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onNext(a)},dispose:function(){this.isDisposed=!0,this.observers=null}}),b.create=function(a,b){return new B(a,b)},b}(h),B=c.AnonymousSubject=function(a){function b(b,c){this.observer=b,this.observable=c,a.call(this)}return s(b,a),t(b.prototype,k.prototype,{_subscribe:function(a){return this.observable.subscribe(a)},onCompleted:function(){this.observer.onCompleted()},onError:function(a){this.observer.onError(a)},onNext:function(a){this.observer.onNext(a)}}),b}(h),C=c.AsyncSubject=function(a){function b(){a.call(this),this.isDisposed=!1,this.isStopped=!1,this.hasValue=!1,this.observers=[],this.hasError=!1}return s(b,a),t(b.prototype,k.prototype,{_subscribe:function(a){return u(this),this.isStopped?(this.hasError?a.onError(this.error):this.hasValue?(a.onNext(this.value),a.onCompleted()):a.onCompleted(),n):(this.observers.push(a),new z(this,a))},hasObservers:function(){return u(this),this.observers.length>0},onCompleted:function(){var a,b;if(u(this),!this.isStopped){this.isStopped=!0;var c=e(this.observers),b=c.length;if(this.hasValue)for(a=0;b>a;a++){var d=c[a];d.onNext(this.value),d.onCompleted()}else for(a=0;b>a;a++)c[a].onCompleted();this.observers.length=0}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.hasError=!0,this.error=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onError(a);this.observers.length=0}},onNext:function(a){u(this),this.isStopped||(this.value=a,this.hasValue=!0)},dispose:function(){this.isDisposed=!0,this.observers=null,this.error=null,this.value=null}}),b}(h),D=c.BehaviorSubject=function(a){function b(b){a.call(this),this.value=b,this.observers=[],this.isDisposed=!1,this.isStopped=!1,this.hasError=!1}return s(b,a),t(b.prototype,k.prototype,{_subscribe:function(a){return u(this),this.isStopped?(this.hasError?a.onError(this.error):a.onCompleted(),n):(this.observers.push(a),a.onNext(this.value),new z(this,a))},getValue:function(){return u(this),this.hasError&&g(this.error),this.value},hasObservers:function(){return this.observers.length>0},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;for(var a=0,b=e(this.observers),c=b.length;c>a;a++)b[a].onCompleted();this.observers.length=0}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.hasError=!0,this.error=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onError(a);this.observers.length=0}},onNext:function(a){if(u(this),!this.isStopped){this.value=a;for(var b=0,c=e(this.observers),d=c.length;d>b;b++)c[b].onNext(a)}},dispose:function(){this.isDisposed=!0,this.observers=null,this.value=null,this.error=null}}),b}(h),E=c.ReplaySubject=function(a){function b(a,b){return m(function(){b.dispose(),!a.isDisposed&&a.observers.splice(a.observers.indexOf(b),1)})}function c(b,c,e){this.bufferSize=null==b?d:b,this.windowSize=null==c?d:c,this.scheduler=e||q,this.q=[],this.observers=[],this.isStopped=!1,this.isDisposed=!1,this.hasError=!1,this.error=null,a.call(this)}var d=Math.pow(2,53)-1;return s(c,a),t(c.prototype,k.prototype,{_subscribe:function(a){u(this);var c=new y(this.scheduler,a),d=b(this,c);this._trim(this.scheduler.now()),this.observers.push(c);for(var e=0,f=this.q.length;f>e;e++)c.onNext(this.q[e].value);return this.hasError?c.onError(this.error):this.isStopped&&c.onCompleted(),c.ensureActive(),d},hasObservers:function(){return this.observers.length>0},_trim:function(a){for(;this.q.length>this.bufferSize;)this.q.shift();for(;this.q.length>0&&a-this.q[0].interval>this.windowSize;)this.q.shift()},onNext:function(a){if(u(this),!this.isStopped){var b=this.scheduler.now();this.q.push({interval:b,value:a}),this._trim(b);for(var c=0,d=e(this.observers),f=d.length;f>c;c++){var g=d[c];g.onNext(a),g.ensureActive()}}},onError:function(a){if(u(this),!this.isStopped){this.isStopped=!0,this.error=a,this.hasError=!0;var b=this.scheduler.now();this._trim(b);for(var c=0,d=e(this.observers),f=d.length;f>c;c++){var g=d[c];g.onError(a),g.ensureActive()}this.observers.length=0}},onCompleted:function(){if(u(this),!this.isStopped){this.isStopped=!0;var a=this.scheduler.now();this._trim(a);for(var b=0,c=e(this.observers),d=c.length;d>b;b++){var f=c[b];f.onCompleted(),f.ensureActive()}this.observers.length=0}},dispose:function(){this.isDisposed=!0,this.observers=null}}),c}(h),F=function(a){function b(b){this.source=b,this._count=0,this._connectableSubscription=null,a.call(this)}function c(a,b){this._p=a,this._s=b,this.isDisposed=!1}return s(b,a),b.prototype.subscribeCore=function(a){var b=this.source.subscribe(a);return 1===++this._count&&(this._connectableSubscription=this.source.connect()),new c(this,b)},c.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,this._s.dispose(),0===--this._p._count&&this._p._connectableSubscription.dispose())},b}(j),G=c.ConnectableObservable=function(a){function b(b,c){this.source=b,this._connection=null,this._source=b.asObservable(),this._subject=c,a.call(this)}function c(a,b){this._p=a,this._s=b}return s(b,a),c.prototype.dispose=function(){this._s&&(this._s.dispose(),this._s=null,this._p._connection=null)},b.prototype.connect=function(){if(!this._connection){var a=this._source.subscribe(this._subject);this._connection=new c(this,a)}return this._connection},b.prototype._subscribe=function(a){return this._subject.subscribe(a)},b.prototype.refCount=function(){return new F(this)},b}(h);return c});
//# sourceMappingURL=rx.core.binding.map

30

dist/rx.core.js

@@ -41,3 +41,3 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

return typeof value == 'function' || false;
}
};

@@ -228,3 +228,2 @@ // fallback for older versions of Chrome and Safari

args = arguments[0];
len = args.length;
} else {

@@ -426,3 +425,3 @@ len = arguments.length;

this.disposable = new SingleAssignmentDisposable();
}
};

@@ -595,3 +594,3 @@ ScheduledItem.prototype.invoke = function () {

*/
Scheduler.prototype.schedulePeriodic = function(state, period, action) {
schedulerProto.schedulePeriodic = function(state, period, action) {
if (typeof root.setInterval === 'undefined') { throw new NotSupportedError(); }

@@ -848,9 +847,8 @@ period = normalizeTime(period);

return function schedule() {
!disposable.isDisposed && disposable.setDisposable(Disposable._fixup(action(scheduler, state)));
disposable.setDisposable(Disposable._fixup(action(scheduler, state)));
};
}
function ClearDisposable(method, id) {
function ClearDisposable(id) {
this._id = id;
this._method = method;
this.isDisposed = false;

@@ -862,10 +860,22 @@ }

this.isDisposed = true;
this._method.call(null, this._id);
clearMethod(this._id);
}
};
function LocalClearDisposable(id) {
this._id = id;
this.isDisposed = false;
}
LocalClearDisposable.prototype.dispose = function () {
if (!this.isDisposed) {
this.isDisposed = true;
localClearTimeout(this._id);
}
};
DefaultScheduler.prototype.schedule = function (state, action) {
var disposable = new SingleAssignmentDisposable(),
id = scheduleMethod(scheduleAction(disposable, action, this, state));
return new BinaryDisposable(disposable, new ClearDisposable(clearMethod, id));
return new BinaryDisposable(disposable, new ClearDisposable(id));
};

@@ -877,3 +887,3 @@

id = localSetTimeout(scheduleAction(disposable, action, this, state), dueTime);
return new BinaryDisposable(disposable, new ClearDisposable(localClearTimeout, id));
return new BinaryDisposable(disposable, new LocalClearDisposable(id));
};

@@ -880,0 +890,0 @@

2

dist/rx.core.min.js
/* Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.*/
(function(a){function b(a){return a&&a.Object===Object?a:null}function c(a){return function(){try{return a.apply(this,arguments)}catch(b){return C.e=b,C}}}function d(a){throw a}function e(a,b){if(E&&b.stack&&"object"==typeof a&&null!==a&&a.stack&&-1===a.stack.indexOf(I)){for(var c=[],d=b;d;d=d.source)d.stack&&c.unshift(d.stack);c.unshift(a.stack);var e=c.join("\n"+I+"\n");a.stack=f(e)}}function f(a){for(var b=a.split("\n"),c=[],d=0,e=b.length;e>d;d++){var f=b[d];g(f)||h(f)||!f||c.push(f)}return c.join("\n")}function g(a){var b=j(a);if(!b)return!1;var c=b[0],d=b[1];return c===G&&d>=H&&pa>=d}function h(a){return-1!==a.indexOf("(module.js:")||-1!==a.indexOf("(node.js:")}function i(){if(E)try{throw new Error}catch(a){var b=a.stack.split("\n"),c=b[0].indexOf("@")>0?b[1]:b[2],d=j(c);if(!d)return;return G=d[0],d[1]}}function j(a){var b=/at .+ \((.+):(\d+):(?:\d+)\)$/.exec(a);if(b)return[b[1],Number(b[2])];var c=/at ([^ ]+):(\d+):(?:\d+)$/.exec(a);if(c)return[c[1],Number(c[2])];var d=/.*@(.+):(\d+)$/.exec(a);return d?[d[1],Number(d[2])]:void 0}function k(a,b){this.id=a,this.value=b}var l={"function":!0,object:!0},m=l[typeof exports]&&exports&&!exports.nodeType?exports:null,n=l[typeof module]&&module&&!module.nodeType?module:null,o=b(m&&n&&"object"==typeof global&&global),p=b(l[typeof self]&&self),q=b(l[typeof window]&&window),r=n&&n.exports===m?m:null,s=b(l[typeof this]&&this),t=o||q!==(s&&s.window)&&q||p||s||Function("return this")(),u={internals:{},config:{Promise:t.Promise},helpers:{}},v=u.helpers.noop=function(){},w=u.helpers.defaultNow=function(){return Date.now?Date.now:function(){return+new Date}}(),x=u.helpers.defaultError=function(a){throw a},y=(u.helpers.isPromise=function(a){return!!a&&!isFunction(a.subscribe)&&isFunction(a.then)},u.helpers.defaultSubComparer=function(a,b){return a>b?1:b>a?-1:0});isFunction=u.helpers.isFunction=function(){var a=function(a){return"function"==typeof a||!1};return a(/x/)&&(a=function(a){return"function"==typeof a&&"[object Function]"==toString.call(a)}),a}();var z=u.NotImplementedError=function(a){this.message=a||"This operation is not implemented",Error.call(this)};z.prototype=Error.prototype;var A=u.NotSupportedError=function(a){this.message=a||"This operation is not supported",Error.call(this)};A.prototype=Error.prototype;var B=u.helpers.notImplemented=function(){throw new z},C=(u.helpers.notSupported=function(){throw new A},{e:{}}),D=u.internals.tryCatch=function(a){if(!isFunction(a))throw new TypeError("fn must be a function");return c(a)};u.config.longStackSupport=!1;var E=!1,F=D(function(){throw new Error})();E=!!F.e&&!!F.e.stack;var G,H=i(),I="From previous event:",J=({}.hasOwnProperty,Array.prototype.slice,u.internals.inherits=function(a,b){function c(){this.constructor=a}c.prototype=b.prototype,a.prototype=new c}),K=(u.internals.addProperties=function(a){for(var b=[],c=1,d=arguments.length;d>c;c++)b.push(arguments[c]);for(var e=0,f=b.length;f>e;e++){var g=b[e];for(var h in g)a[h]=g[h]}},u.internals.addRef=function(a,b){return new na(function(c){return new T(b.getDisposable(),a.subscribe(c))})},u.CompositeDisposable=function(){var a,b,c=[];if(Array.isArray(arguments[0]))c=arguments[0],b=c.length;else for(b=arguments.length,c=new Array(b),a=0;b>a;a++)c[a]=arguments[a];this.disposables=c,this.isDisposed=!1,this.length=c.length}),L=K.prototype;L.add=function(a){this.isDisposed?a.dispose():(this.disposables.push(a),this.length++)},L.remove=function(a){var b=!1;if(!this.isDisposed){var c=this.disposables.indexOf(a);-1!==c&&(b=!0,this.disposables.splice(c,1),this.length--,a.dispose())}return b},L.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;for(var a=this.disposables.length,b=new Array(a),c=0;a>c;c++)b[c]=this.disposables[c];for(this.disposables=[],this.length=0,c=0;a>c;c++)b[c].dispose()}};var M=u.Disposable=function(a){this.isDisposed=!1,this.action=a||v};M.prototype.dispose=function(){this.isDisposed||(this.action(),this.isDisposed=!0)};var N=M.create=function(a){return new M(a)},O=M.empty={dispose:v},P=M.isDisposable=function(a){return a&&isFunction(a.dispose)},Q=(M.checkDisposed=function(a){if(a.isDisposed)throw new ObjectDisposedError},M._fixup=function(a){return P(a)?a:O}),R=u.SingleAssignmentDisposable=function(){this.isDisposed=!1,this.current=null};R.prototype.getDisposable=function(){return this.current},R.prototype.setDisposable=function(a){if(this.current)throw new Error("Disposable has already been assigned");var b=this.isDisposed;!b&&(this.current=a),b&&a&&a.dispose()},R.prototype.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;var a=this.current;this.current=null,a&&a.dispose()}};var S=u.SerialDisposable=function(){this.isDisposed=!1,this.current=null};S.prototype.getDisposable=function(){return this.current},S.prototype.setDisposable=function(a){var b=this.isDisposed;if(!b){var c=this.current;this.current=a}c&&c.dispose(),b&&a&&a.dispose()},S.prototype.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;var a=this.current;this.current=null}a&&a.dispose()};var T=u.BinaryDisposable=function(a,b){this._first=a,this._second=b,this.isDisposed=!1};T.prototype.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;var a=this._first;this._first=null,a&&a.dispose();var b=this._second;this._second=null,b&&b.dispose()}};var U=u.NAryDisposable=function(a){this._disposables=a,this.isDisposed=!1};U.prototype.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;for(var a=0,b=this._disposables.length;b>a;a++)this._disposables[a].dispose();this._disposables.length=0}};var V=u.internals.ScheduledItem=function(a,b,c,d,e){this.scheduler=a,this.state=b,this.action=c,this.dueTime=d,this.comparer=e||y,this.disposable=new R};V.prototype.invoke=function(){this.disposable.setDisposable(this.invokeCore())},V.prototype.compareTo=function(a){return this.comparer(this.dueTime,a.dueTime)},V.prototype.isCancelled=function(){return this.disposable.isDisposed},V.prototype.invokeCore=function(){return Q(this.action(this.scheduler,this.state))};var W=u.Scheduler=function(){function a(){}a.isScheduler=function(b){return b instanceof a};var b=a.prototype;return b.schedule=function(a,b){throw new z},b.scheduleFuture=function(b,c,d){var e=c;return e instanceof Date&&(e-=this.now()),e=a.normalize(e),0===e?this.schedule(b,d):this._scheduleFuture(b,e,d)},b._scheduleFuture=function(a,b,c){throw new z},a.now=w,a.prototype.now=w,a.normalize=function(a){return 0>a&&(a=0),a},a}(),X=W.normalize;W.isScheduler;!function(a){function b(a,b){function c(b){function d(a,b){return g?f.remove(i):h=!0,e(b,c),O}var g=!1,h=!1,i=a.schedule(b,d);h||(f.add(i),g=!0)}var d=b[0],e=b[1],f=new K;return e(d,c),f}function c(a,b){function c(b,d){function g(a,b){return h?f.remove(j):i=!0,e(b,c),O}var h=!1,i=!1,j=a.scheduleFuture(b,d,g);i||(f.add(j),h=!0)}var d=b[0],e=b[1],f=new K;return e(d,c),f}a.scheduleRecursive=function(a,c){return this.schedule([a,c],b)},a.scheduleRecursiveFuture=function(a,b,d){return this.scheduleFuture([a,d],b,c)}}(W.prototype),function(a){W.prototype.schedulePeriodic=function(a,b,c){if("undefined"==typeof t.setInterval)throw new A;b=X(b);var d=a,e=t.setInterval(function(){d=c(d)},b);return N(function(){t.clearInterval(e)})}}(W.prototype);var Y,Z,$=(u.internals.SchedulePeriodicRecursive=function(){function a(a){return function(b,c){c(0,a._period);var e=D(a._action)(a._state);e===C&&(a._cancel.dispose(),d(e.e)),a._state=e}}function b(a,b,c,d){this._scheduler=a,this._state=b,this._period=c,this._action=d}return b.prototype.start=function(){var b=new R;return this._cancel=b,b.setDisposable(this._scheduler.scheduleRecursiveFuture(0,this._period,a(this))),b},b}(),function(a){function b(){a.call(this)}return J(b,a),b.prototype.schedule=function(a,b){return Q(b(this,a))},b}(W)),_=(W.immediate=new $,function(a){function b(){for(;e.length>0;){var a=e.dequeue();!a.isCancelled()&&a.invoke()}}function c(){a.call(this)}var e;return J(c,a),c.prototype.schedule=function(a,c){var f=new V(this,a,c,this.now());if(e)e.enqueue(f);else{e=new fa(4),e.enqueue(f);var g=D(b)();e=null,g===C&&d(g.e)}return f.disposable},c.prototype.scheduleRequired=function(){return!e},c}(W)),aa=W.currentThread=new _,ba=function(){var a,b=v;if(t.setTimeout)a=t.setTimeout,b=t.clearTimeout;else{if(!t.WScript)throw new A;a=function(a,b){t.WScript.Sleep(b),a()}}return{setTimeout:a,clearTimeout:b}}(),ca=ba.setTimeout,da=ba.clearTimeout;!function(){function a(b){if(f)ca(function(){a(b)},0);else{var c=e[b];if(c){f=!0;var g=D(c)();Z(b),f=!1,g===C&&d(g.e)}}}function b(){if(!t.postMessage||t.importScripts)return!1;var a=!1,b=t.onmessage;return t.onmessage=function(){a=!0},t.postMessage("","*"),t.onmessage=b,a}var c=1,e={},f=!1;Z=function(a){delete e[a]};var g=new RegExp("^"+String(toString).replace(/[.*+?^${}()|[\]\\]/g,"\\$&").replace(/toString| for [^\]]+/g,".*?")+"$"),h="function"==typeof(h=o&&r&&o.setImmediate)&&!g.test(h)&&h;if(isFunction(h))Y=function(b){var d=c++;return e[d]=b,h(function(){a(d)}),d};else if("undefined"!=typeof process&&"[object process]"==={}.toString.call(process))Y=function(b){var d=c++;return e[d]=b,process.nextTick(function(){a(d)}),d};else if(b()){var i="ms.rx.schedule"+Math.random(),j=function(b){"string"==typeof b.data&&b.data.substring(0,i.length)===i&&a(b.data.substring(i.length))};t.addEventListener("message",j,!1),Y=function(a){var b=c++;return e[b]=a,t.postMessage(i+currentId,"*"),b}}else if(t.MessageChannel){var k=new t.MessageChannel;k.port1.onmessage=function(b){a(b.data)},Y=function(a){var b=c++;return e[b]=a,k.port2.postMessage(b),b}}else Y="document"in t&&"onreadystatechange"in t.document.createElement("script")?function(b){var d=t.document.createElement("script"),f=c++;return e[f]=b,d.onreadystatechange=function(){a(f),d.onreadystatechange=null,d.parentNode.removeChild(d),d=null},t.document.documentElement.appendChild(d),f}:function(b){var d=c++;return e[d]=b,ca(function(){a(d)},0),d}}();var ea=function(a){function b(){a.call(this)}function c(a,b,c,d){return function(){!a.isDisposed&&a.setDisposable(M._fixup(b(c,d)))}}function d(a,b){this._id=b,this._method=a,this.isDisposed=!1}return J(b,a),d.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,this._method.call(null,this._id))},b.prototype.schedule=function(a,b){var e=new R,f=Y(c(e,b,this,a));return new T(e,new d(Z,f))},b.prototype._scheduleFuture=function(a,b,e){if(0===b)return this.schedule(a,e);var f=new R,g=ca(c(f,e,this,a),b);return new T(f,new d(da,g))},b}(W);W["default"]=W.async=new ea;k.prototype.compareTo=function(a){var b=this.value.compareTo(a.value);return 0===b&&(b=this.id-a.id),b};var fa=u.internals.PriorityQueue=function(a){this.items=new Array(a),this.length=0},ga=fa.prototype;ga.isHigherPriority=function(a,b){return this.items[a].compareTo(this.items[b])<0},ga.percolate=function(a){if(!(a>=this.length||0>a)){var b=a-1>>1;if(!(0>b||b===a)&&this.isHigherPriority(a,b)){var c=this.items[a];this.items[a]=this.items[b],this.items[b]=c,this.percolate(b)}}},ga.heapify=function(a){if(+a||(a=0),!(a>=this.length||0>a)){var b=2*a+1,c=2*a+2,d=a;if(b<this.length&&this.isHigherPriority(b,d)&&(d=b),c<this.length&&this.isHigherPriority(c,d)&&(d=c),d!==a){var e=this.items[a];this.items[a]=this.items[d],this.items[d]=e,this.heapify(d)}}},ga.peek=function(){return this.items[0].value},ga.removeAt=function(b){this.items[b]=this.items[--this.length],this.items[this.length]=a,this.heapify()},ga.dequeue=function(){var a=this.peek();return this.removeAt(0),a},ga.enqueue=function(a){var b=this.length++;this.items[b]=new k(fa.count++,a),this.percolate(b)},ga.remove=function(a){for(var b=0;b<this.length;b++)if(this.items[b].value===a)return this.removeAt(b),!0;return!1},fa.count=0;var ha,ia=u.Observer=function(){},ja=ia.create=function(a,b,c){return a||(a=v),b||(b=x),c||(c=v),new la(a,b,c)},ka=u.internals.AbstractObserver=function(a){function b(){this.isStopped=!1}return J(b,a),b.prototype.next=B,b.prototype.error=B,b.prototype.completed=B,b.prototype.onNext=function(a){!this.isStopped&&this.next(a)},b.prototype.onError=function(a){this.isStopped||(this.isStopped=!0,this.error(a))},b.prototype.onCompleted=function(){this.isStopped||(this.isStopped=!0,this.completed())},b.prototype.dispose=function(){this.isStopped=!0},b.prototype.fail=function(a){return this.isStopped?!1:(this.isStopped=!0,this.error(a),!0)},b}(ia),la=u.AnonymousObserver=function(a){function b(b,c,d){a.call(this),this._onNext=b,this._onError=c,this._onCompleted=d}return J(b,a),b.prototype.next=function(a){this._onNext(a)},b.prototype.error=function(a){this._onError(a)},b.prototype.completed=function(){this._onCompleted()},b}(ka),ma=u.Observable=function(){function a(a,b){return function(c){var d=c.onError;return c.onError=function(b){e(b,a),d.call(c,b)},b.call(a,c)}}function b(){if(u.config.longStackSupport&&E){var b=this._subscribe,c=D(d)(new Error).e;this.stack=c.stack.substring(c.stack.indexOf("\n")+1),this._subscribe=a(this,b)}}return ha=b.prototype,b.isObservable=function(a){return a&&isFunction(a.subscribe)},ha.subscribe=ha.forEach=function(a,b,c){return this._subscribe("object"==typeof a?a:ja(a,b,c))},ha.subscribeOnNext=function(a,b){return this._subscribe(ja("undefined"!=typeof b?function(c){a.call(b,c)}:a))},ha.subscribeOnError=function(a,b){return this._subscribe(ja(null,"undefined"!=typeof b?function(c){a.call(b,c)}:a))},ha.subscribeOnCompleted=function(a,b){return this._subscribe(ja(null,null,"undefined"!=typeof b?function(){a.call(b)}:a))},b}(),na=u.AnonymousObservable=function(a){function b(a){return a&&isFunction(a.dispose)?a:isFunction(a)?N(a):O}function c(a,c){var e=c[0],f=c[1],g=D(f.__subscribe).call(f,e);g!==C||e.fail(C.e)||d(C.e),e.setDisposable(b(g))}function e(b,c){this.source=c,this.__subscribe=b,a.call(this)}return J(e,a),e.prototype._subscribe=function(a){var b=new oa(a),d=[b,this];return aa.scheduleRequired()?aa.schedule(d,c):c(null,d),b},e}(ma),oa=(u.ObservableBase=function(a){function b(a){return a&&isFunction(a.dispose)?a:isFunction(a)?N(a):O}function c(a,c){var e=c[0],f=c[1],g=D(f.subscribeCore).call(f,e);g!==C||e.fail(C.e)||d(C.e),e.setDisposable(b(g))}function e(){a.call(this)}return J(e,a),e.prototype._subscribe=function(a){var b=new oa(a),d=[b,this];return aa.scheduleRequired()?aa.schedule(d,c):c(null,d),b},e.prototype.subscribeCore=B,e}(ma),function(a){function b(b){a.call(this),this.observer=b,this.m=new R}J(b,a);var c=b.prototype;return c.next=function(a){var b=D(this.observer.onNext).call(this.observer,a);b===C&&(this.dispose(),d(b.e))},c.error=function(a){var b=D(this.observer.onError).call(this.observer,a);this.dispose(),b===C&&d(b.e)},c.completed=function(){var a=D(this.observer.onCompleted).call(this.observer);this.dispose(),a===C&&d(a.e)},c.setDisposable=function(a){this.m.setDisposable(a)},c.getDisposable=function(){return this.m.getDisposable()},c.dispose=function(){a.prototype.dispose.call(this),this.m.dispose()},b}(ka));ma.create=function(a,b){return new na(a,b)},"function"==typeof define&&"object"==typeof define.amd&&define.amd?(t.Rx=u,define(function(){return u})):m&&n?r?(n.exports=u).Rx=u:m.Rx=u:t.Rx=u;var pa=i()}).call(this);
(function(a){function b(a){return a&&a.Object===Object?a:null}function c(a){return function(){try{return a.apply(this,arguments)}catch(b){return C.e=b,C}}}function d(a){throw a}function e(a,b){if(E&&b.stack&&"object"==typeof a&&null!==a&&a.stack&&-1===a.stack.indexOf(I)){for(var c=[],d=b;d;d=d.source)d.stack&&c.unshift(d.stack);c.unshift(a.stack);var e=c.join("\n"+I+"\n");a.stack=f(e)}}function f(a){for(var b=a.split("\n"),c=[],d=0,e=b.length;e>d;d++){var f=b[d];g(f)||h(f)||!f||c.push(f)}return c.join("\n")}function g(a){var b=j(a);if(!b)return!1;var c=b[0],d=b[1];return c===G&&d>=H&&pa>=d}function h(a){return-1!==a.indexOf("(module.js:")||-1!==a.indexOf("(node.js:")}function i(){if(E)try{throw new Error}catch(a){var b=a.stack.split("\n"),c=b[0].indexOf("@")>0?b[1]:b[2],d=j(c);if(!d)return;return G=d[0],d[1]}}function j(a){var b=/at .+ \((.+):(\d+):(?:\d+)\)$/.exec(a);if(b)return[b[1],Number(b[2])];var c=/at ([^ ]+):(\d+):(?:\d+)$/.exec(a);if(c)return[c[1],Number(c[2])];var d=/.*@(.+):(\d+)$/.exec(a);return d?[d[1],Number(d[2])]:void 0}function k(a,b){this.id=a,this.value=b}var l={"function":!0,object:!0},m=l[typeof exports]&&exports&&!exports.nodeType?exports:null,n=l[typeof module]&&module&&!module.nodeType?module:null,o=b(m&&n&&"object"==typeof global&&global),p=b(l[typeof self]&&self),q=b(l[typeof window]&&window),r=n&&n.exports===m?m:null,s=b(l[typeof this]&&this),t=o||q!==(s&&s.window)&&q||p||s||Function("return this")(),u={internals:{},config:{Promise:t.Promise},helpers:{}},v=u.helpers.noop=function(){},w=u.helpers.defaultNow=function(){return Date.now?Date.now:function(){return+new Date}}(),x=u.helpers.defaultError=function(a){throw a},y=(u.helpers.isPromise=function(a){return!!a&&!isFunction(a.subscribe)&&isFunction(a.then)},u.helpers.defaultSubComparer=function(a,b){return a>b?1:b>a?-1:0});isFunction=u.helpers.isFunction=function(){var a=function(a){return"function"==typeof a||!1};return a(/x/)&&(a=function(a){return"function"==typeof a&&"[object Function]"==toString.call(a)}),a}();var z=u.NotImplementedError=function(a){this.message=a||"This operation is not implemented",Error.call(this)};z.prototype=Error.prototype;var A=u.NotSupportedError=function(a){this.message=a||"This operation is not supported",Error.call(this)};A.prototype=Error.prototype;var B=u.helpers.notImplemented=function(){throw new z},C=(u.helpers.notSupported=function(){throw new A},{e:{}}),D=u.internals.tryCatch=function(a){if(!isFunction(a))throw new TypeError("fn must be a function");return c(a)};u.config.longStackSupport=!1;var E=!1,F=D(function(){throw new Error})();E=!!F.e&&!!F.e.stack;var G,H=i(),I="From previous event:",J=({}.hasOwnProperty,Array.prototype.slice,u.internals.inherits=function(a,b){function c(){this.constructor=a}c.prototype=b.prototype,a.prototype=new c}),K=(u.internals.addProperties=function(a){for(var b=[],c=1,d=arguments.length;d>c;c++)b.push(arguments[c]);for(var e=0,f=b.length;f>e;e++){var g=b[e];for(var h in g)a[h]=g[h]}},u.internals.addRef=function(a,b){return new na(function(c){return new T(b.getDisposable(),a.subscribe(c))})},u.CompositeDisposable=function(){var a,b,c=[];if(Array.isArray(arguments[0]))c=arguments[0];else for(b=arguments.length,c=new Array(b),a=0;b>a;a++)c[a]=arguments[a];this.disposables=c,this.isDisposed=!1,this.length=c.length}),L=K.prototype;L.add=function(a){this.isDisposed?a.dispose():(this.disposables.push(a),this.length++)},L.remove=function(a){var b=!1;if(!this.isDisposed){var c=this.disposables.indexOf(a);-1!==c&&(b=!0,this.disposables.splice(c,1),this.length--,a.dispose())}return b},L.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;for(var a=this.disposables.length,b=new Array(a),c=0;a>c;c++)b[c]=this.disposables[c];for(this.disposables=[],this.length=0,c=0;a>c;c++)b[c].dispose()}};var M=u.Disposable=function(a){this.isDisposed=!1,this.action=a||v};M.prototype.dispose=function(){this.isDisposed||(this.action(),this.isDisposed=!0)};var N=M.create=function(a){return new M(a)},O=M.empty={dispose:v},P=M.isDisposable=function(a){return a&&isFunction(a.dispose)},Q=(M.checkDisposed=function(a){if(a.isDisposed)throw new ObjectDisposedError},M._fixup=function(a){return P(a)?a:O}),R=u.SingleAssignmentDisposable=function(){this.isDisposed=!1,this.current=null};R.prototype.getDisposable=function(){return this.current},R.prototype.setDisposable=function(a){if(this.current)throw new Error("Disposable has already been assigned");var b=this.isDisposed;!b&&(this.current=a),b&&a&&a.dispose()},R.prototype.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;var a=this.current;this.current=null,a&&a.dispose()}};var S=u.SerialDisposable=function(){this.isDisposed=!1,this.current=null};S.prototype.getDisposable=function(){return this.current},S.prototype.setDisposable=function(a){var b=this.isDisposed;if(!b){var c=this.current;this.current=a}c&&c.dispose(),b&&a&&a.dispose()},S.prototype.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;var a=this.current;this.current=null}a&&a.dispose()};var T=u.BinaryDisposable=function(a,b){this._first=a,this._second=b,this.isDisposed=!1};T.prototype.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;var a=this._first;this._first=null,a&&a.dispose();var b=this._second;this._second=null,b&&b.dispose()}};var U=u.NAryDisposable=function(a){this._disposables=a,this.isDisposed=!1};U.prototype.dispose=function(){if(!this.isDisposed){this.isDisposed=!0;for(var a=0,b=this._disposables.length;b>a;a++)this._disposables[a].dispose();this._disposables.length=0}};var V=u.internals.ScheduledItem=function(a,b,c,d,e){this.scheduler=a,this.state=b,this.action=c,this.dueTime=d,this.comparer=e||y,this.disposable=new R};V.prototype.invoke=function(){this.disposable.setDisposable(this.invokeCore())},V.prototype.compareTo=function(a){return this.comparer(this.dueTime,a.dueTime)},V.prototype.isCancelled=function(){return this.disposable.isDisposed},V.prototype.invokeCore=function(){return Q(this.action(this.scheduler,this.state))};var W=u.Scheduler=function(){function a(){}a.isScheduler=function(b){return b instanceof a};var b=a.prototype;return b.schedule=function(a,b){throw new z},b.scheduleFuture=function(b,c,d){var e=c;return e instanceof Date&&(e-=this.now()),e=a.normalize(e),0===e?this.schedule(b,d):this._scheduleFuture(b,e,d)},b._scheduleFuture=function(a,b,c){throw new z},a.now=w,a.prototype.now=w,a.normalize=function(a){return 0>a&&(a=0),a},a}(),X=W.normalize;W.isScheduler;!function(a){function b(a,b){function c(b){function d(a,b){return g?f.remove(i):h=!0,e(b,c),O}var g=!1,h=!1,i=a.schedule(b,d);h||(f.add(i),g=!0)}var d=b[0],e=b[1],f=new K;return e(d,c),f}function c(a,b){function c(b,d){function g(a,b){return h?f.remove(j):i=!0,e(b,c),O}var h=!1,i=!1,j=a.scheduleFuture(b,d,g);i||(f.add(j),h=!0)}var d=b[0],e=b[1],f=new K;return e(d,c),f}a.scheduleRecursive=function(a,c){return this.schedule([a,c],b)},a.scheduleRecursiveFuture=function(a,b,d){return this.scheduleFuture([a,d],b,c)}}(W.prototype),function(a){a.schedulePeriodic=function(a,b,c){if("undefined"==typeof t.setInterval)throw new A;b=X(b);var d=a,e=t.setInterval(function(){d=c(d)},b);return N(function(){t.clearInterval(e)})}}(W.prototype);var Y,Z,$=(u.internals.SchedulePeriodicRecursive=function(){function a(a){return function(b,c){c(0,a._period);var e=D(a._action)(a._state);e===C&&(a._cancel.dispose(),d(e.e)),a._state=e}}function b(a,b,c,d){this._scheduler=a,this._state=b,this._period=c,this._action=d}return b.prototype.start=function(){var b=new R;return this._cancel=b,b.setDisposable(this._scheduler.scheduleRecursiveFuture(0,this._period,a(this))),b},b}(),function(a){function b(){a.call(this)}return J(b,a),b.prototype.schedule=function(a,b){return Q(b(this,a))},b}(W)),_=(W.immediate=new $,function(a){function b(){for(;e.length>0;){var a=e.dequeue();!a.isCancelled()&&a.invoke()}}function c(){a.call(this)}var e;return J(c,a),c.prototype.schedule=function(a,c){var f=new V(this,a,c,this.now());if(e)e.enqueue(f);else{e=new fa(4),e.enqueue(f);var g=D(b)();e=null,g===C&&d(g.e)}return f.disposable},c.prototype.scheduleRequired=function(){return!e},c}(W)),aa=W.currentThread=new _,ba=function(){var a,b=v;if(t.setTimeout)a=t.setTimeout,b=t.clearTimeout;else{if(!t.WScript)throw new A;a=function(a,b){t.WScript.Sleep(b),a()}}return{setTimeout:a,clearTimeout:b}}(),ca=ba.setTimeout,da=ba.clearTimeout;!function(){function a(b){if(f)ca(function(){a(b)},0);else{var c=e[b];if(c){f=!0;var g=D(c)();Z(b),f=!1,g===C&&d(g.e)}}}function b(){if(!t.postMessage||t.importScripts)return!1;var a=!1,b=t.onmessage;return t.onmessage=function(){a=!0},t.postMessage("","*"),t.onmessage=b,a}var c=1,e={},f=!1;Z=function(a){delete e[a]};var g=new RegExp("^"+String(toString).replace(/[.*+?^${}()|[\]\\]/g,"\\$&").replace(/toString| for [^\]]+/g,".*?")+"$"),h="function"==typeof(h=o&&r&&o.setImmediate)&&!g.test(h)&&h;if(isFunction(h))Y=function(b){var d=c++;return e[d]=b,h(function(){a(d)}),d};else if("undefined"!=typeof process&&"[object process]"==={}.toString.call(process))Y=function(b){var d=c++;return e[d]=b,process.nextTick(function(){a(d)}),d};else if(b()){var i="ms.rx.schedule"+Math.random(),j=function(b){"string"==typeof b.data&&b.data.substring(0,i.length)===i&&a(b.data.substring(i.length))};t.addEventListener("message",j,!1),Y=function(a){var b=c++;return e[b]=a,t.postMessage(i+currentId,"*"),b}}else if(t.MessageChannel){var k=new t.MessageChannel;k.port1.onmessage=function(b){a(b.data)},Y=function(a){var b=c++;return e[b]=a,k.port2.postMessage(b),b}}else Y="document"in t&&"onreadystatechange"in t.document.createElement("script")?function(b){var d=t.document.createElement("script"),f=c++;return e[f]=b,d.onreadystatechange=function(){a(f),d.onreadystatechange=null,d.parentNode.removeChild(d),d=null},t.document.documentElement.appendChild(d),f}:function(b){var d=c++;return e[d]=b,ca(function(){a(d)},0),d}}();var ea=function(a){function b(){a.call(this)}function c(a,b,c,d){return function(){a.setDisposable(M._fixup(b(c,d)))}}function d(a){this._id=a,this.isDisposed=!1}function e(a){this._id=a,this.isDisposed=!1}return J(b,a),d.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,Z(this._id))},e.prototype.dispose=function(){this.isDisposed||(this.isDisposed=!0,da(this._id))},b.prototype.schedule=function(a,b){var e=new R,f=Y(c(e,b,this,a));return new T(e,new d(f))},b.prototype._scheduleFuture=function(a,b,d){if(0===b)return this.schedule(a,d);var f=new R,g=ca(c(f,d,this,a),b);return new T(f,new e(g))},b}(W);W["default"]=W.async=new ea;k.prototype.compareTo=function(a){var b=this.value.compareTo(a.value);return 0===b&&(b=this.id-a.id),b};var fa=u.internals.PriorityQueue=function(a){this.items=new Array(a),this.length=0},ga=fa.prototype;ga.isHigherPriority=function(a,b){return this.items[a].compareTo(this.items[b])<0},ga.percolate=function(a){if(!(a>=this.length||0>a)){var b=a-1>>1;if(!(0>b||b===a)&&this.isHigherPriority(a,b)){var c=this.items[a];this.items[a]=this.items[b],this.items[b]=c,this.percolate(b)}}},ga.heapify=function(a){if(+a||(a=0),!(a>=this.length||0>a)){var b=2*a+1,c=2*a+2,d=a;if(b<this.length&&this.isHigherPriority(b,d)&&(d=b),c<this.length&&this.isHigherPriority(c,d)&&(d=c),d!==a){var e=this.items[a];this.items[a]=this.items[d],this.items[d]=e,this.heapify(d)}}},ga.peek=function(){return this.items[0].value},ga.removeAt=function(b){this.items[b]=this.items[--this.length],this.items[this.length]=a,this.heapify()},ga.dequeue=function(){var a=this.peek();return this.removeAt(0),a},ga.enqueue=function(a){var b=this.length++;this.items[b]=new k(fa.count++,a),this.percolate(b)},ga.remove=function(a){for(var b=0;b<this.length;b++)if(this.items[b].value===a)return this.removeAt(b),!0;return!1},fa.count=0;var ha,ia=u.Observer=function(){},ja=ia.create=function(a,b,c){return a||(a=v),b||(b=x),c||(c=v),new la(a,b,c)},ka=u.internals.AbstractObserver=function(a){function b(){this.isStopped=!1}return J(b,a),b.prototype.next=B,b.prototype.error=B,b.prototype.completed=B,b.prototype.onNext=function(a){!this.isStopped&&this.next(a)},b.prototype.onError=function(a){this.isStopped||(this.isStopped=!0,this.error(a))},b.prototype.onCompleted=function(){this.isStopped||(this.isStopped=!0,this.completed())},b.prototype.dispose=function(){this.isStopped=!0},b.prototype.fail=function(a){return this.isStopped?!1:(this.isStopped=!0,this.error(a),!0)},b}(ia),la=u.AnonymousObserver=function(a){function b(b,c,d){a.call(this),this._onNext=b,this._onError=c,this._onCompleted=d}return J(b,a),b.prototype.next=function(a){this._onNext(a)},b.prototype.error=function(a){this._onError(a)},b.prototype.completed=function(){this._onCompleted()},b}(ka),ma=u.Observable=function(){function a(a,b){return function(c){var d=c.onError;return c.onError=function(b){e(b,a),d.call(c,b)},b.call(a,c)}}function b(){if(u.config.longStackSupport&&E){var b=this._subscribe,c=D(d)(new Error).e;this.stack=c.stack.substring(c.stack.indexOf("\n")+1),this._subscribe=a(this,b)}}return ha=b.prototype,b.isObservable=function(a){return a&&isFunction(a.subscribe)},ha.subscribe=ha.forEach=function(a,b,c){return this._subscribe("object"==typeof a?a:ja(a,b,c))},ha.subscribeOnNext=function(a,b){return this._subscribe(ja("undefined"!=typeof b?function(c){a.call(b,c)}:a))},ha.subscribeOnError=function(a,b){return this._subscribe(ja(null,"undefined"!=typeof b?function(c){a.call(b,c)}:a))},ha.subscribeOnCompleted=function(a,b){return this._subscribe(ja(null,null,"undefined"!=typeof b?function(){a.call(b)}:a))},b}(),na=u.AnonymousObservable=function(a){function b(a){return a&&isFunction(a.dispose)?a:isFunction(a)?N(a):O}function c(a,c){var e=c[0],f=c[1],g=D(f.__subscribe).call(f,e);g!==C||e.fail(C.e)||d(C.e),e.setDisposable(b(g))}function e(b,c){this.source=c,this.__subscribe=b,a.call(this)}return J(e,a),e.prototype._subscribe=function(a){var b=new oa(a),d=[b,this];return aa.scheduleRequired()?aa.schedule(d,c):c(null,d),b},e}(ma),oa=(u.ObservableBase=function(a){function b(a){return a&&isFunction(a.dispose)?a:isFunction(a)?N(a):O}function c(a,c){var e=c[0],f=c[1],g=D(f.subscribeCore).call(f,e);g!==C||e.fail(C.e)||d(C.e),e.setDisposable(b(g))}function e(){a.call(this)}return J(e,a),e.prototype._subscribe=function(a){var b=new oa(a),d=[b,this];return aa.scheduleRequired()?aa.schedule(d,c):c(null,d),b},e.prototype.subscribeCore=B,e}(ma),function(a){function b(b){a.call(this),this.observer=b,this.m=new R}J(b,a);var c=b.prototype;return c.next=function(a){var b=D(this.observer.onNext).call(this.observer,a);b===C&&(this.dispose(),d(b.e))},c.error=function(a){var b=D(this.observer.onError).call(this.observer,a);this.dispose(),b===C&&d(b.e)},c.completed=function(){var a=D(this.observer.onCompleted).call(this.observer);this.dispose(),a===C&&d(a.e)},c.setDisposable=function(a){this.m.setDisposable(a)},c.getDisposable=function(){return this.m.getDisposable()},c.dispose=function(){a.prototype.dispose.call(this),this.m.dispose()},b}(ka));ma.create=function(a,b){return new na(a,b)},"function"==typeof define&&"object"==typeof define.amd&&define.amd?(t.Rx=u,define(function(){return u})):m&&n?r?(n.exports=u).Rx=u:m.Rx=u:t.Rx=u;var pa=i()}).call(this);
//# sourceMappingURL=rx.core.map

497

dist/rx.core.testing.js

@@ -62,3 +62,3 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

Notification.prototype._acceptObservable = function (onNext, onError, onCompleted) {
Notification.prototype._acceptObserver = function (onNext, onError, onCompleted) {
throw new NotImplementedError();

@@ -69,7 +69,5 @@ };

* Invokes the delegate corresponding to the notification or the observer's method corresponding to the notification and returns the produced result.
*
* @memberOf Notification
* @param {Any} observerOrOnNext Delegate to invoke for an OnNext notification or Observer to invoke the notification on..
* @param {Function} onError Delegate to invoke for an OnError notification.
* @param {Function} onCompleted Delegate to invoke for an OnCompleted notification.
* @param {Function | Observer} observerOrOnNext Function to invoke for an OnNext notification or Observer to invoke the notification on..
* @param {Function} onError Function to invoke for an OnError notification.
* @param {Function} onCompleted Function to invoke for an OnCompleted notification.
* @returns {Any} Result produced by the observation.

@@ -79,3 +77,3 @@ */

return observerOrOnNext && typeof observerOrOnNext === 'object' ?
this._acceptObservable(observerOrOnNext) :
this._acceptObserver(observerOrOnNext) :
this._accept(observerOrOnNext, onError, onCompleted);

@@ -96,3 +94,3 @@ };

return scheduler.schedule(self, function (_, notification) {
notification._acceptObservable(o);
notification._acceptObserver(o);
notification.kind === 'N' && o.onCompleted();

@@ -117,3 +115,3 @@ });

OnNextNotification.prototype._acceptObservable = function (o) {
OnNextNotification.prototype._acceptObserver = function (o) {
return o.onNext(this.value);

@@ -140,3 +138,3 @@ };

OnErrorNotification.prototype._acceptObservable = function (o) {
OnErrorNotification.prototype._acceptObserver = function (o) {
return o.onError(this.error);

@@ -162,3 +160,3 @@ };

OnCompletedNotification.prototype._acceptObservable = function (o) {
OnCompletedNotification.prototype._acceptObserver = function (o) {
return o.onCompleted();

@@ -210,277 +208,300 @@ };

/** `Object#toString` result shortcuts */
var argsClass = '[object Arguments]',
arrayClass = '[object Array]',
boolClass = '[object Boolean]',
dateClass = '[object Date]',
errorClass = '[object Error]',
funcClass = '[object Function]',
numberClass = '[object Number]',
objectClass = '[object Object]',
regexpClass = '[object RegExp]',
stringClass = '[object String]';
var argsTag = '[object Arguments]',
arrayTag = '[object Array]',
boolTag = '[object Boolean]',
dateTag = '[object Date]',
errorTag = '[object Error]',
funcTag = '[object Function]',
mapTag = '[object Map]',
numberTag = '[object Number]',
objectTag = '[object Object]',
regexpTag = '[object RegExp]',
setTag = '[object Set]',
stringTag = '[object String]',
weakMapTag = '[object WeakMap]';
var toString = Object.prototype.toString,
hasOwnProperty = Object.prototype.hasOwnProperty,
supportsArgsClass = toString.call(arguments) == argsClass, // For less <IE9 && FF<4
supportNodeClass,
errorProto = Error.prototype,
objectProto = Object.prototype,
stringProto = String.prototype,
propertyIsEnumerable = objectProto.propertyIsEnumerable;
var arrayBufferTag = '[object ArrayBuffer]',
float32Tag = '[object Float32Array]',
float64Tag = '[object Float64Array]',
int8Tag = '[object Int8Array]',
int16Tag = '[object Int16Array]',
int32Tag = '[object Int32Array]',
uint8Tag = '[object Uint8Array]',
uint8ClampedTag = '[object Uint8ClampedArray]',
uint16Tag = '[object Uint16Array]',
uint32Tag = '[object Uint32Array]';
try {
supportNodeClass = !(toString.call(document) == objectClass && !({ 'toString': 0 } + ''));
} catch (e) {
supportNodeClass = true;
}
var typedArrayTags = {};
typedArrayTags[float32Tag] = typedArrayTags[float64Tag] =
typedArrayTags[int8Tag] = typedArrayTags[int16Tag] =
typedArrayTags[int32Tag] = typedArrayTags[uint8Tag] =
typedArrayTags[uint8ClampedTag] = typedArrayTags[uint16Tag] =
typedArrayTags[uint32Tag] = true;
typedArrayTags[argsTag] = typedArrayTags[arrayTag] =
typedArrayTags[arrayBufferTag] = typedArrayTags[boolTag] =
typedArrayTags[dateTag] = typedArrayTags[errorTag] =
typedArrayTags[funcTag] = typedArrayTags[mapTag] =
typedArrayTags[numberTag] = typedArrayTags[objectTag] =
typedArrayTags[regexpTag] = typedArrayTags[setTag] =
typedArrayTags[stringTag] = typedArrayTags[weakMapTag] = false;
var nonEnumProps = {};
nonEnumProps[arrayClass] = nonEnumProps[dateClass] = nonEnumProps[numberClass] = { 'constructor': true, 'toLocaleString': true, 'toString': true, 'valueOf': true };
nonEnumProps[boolClass] = nonEnumProps[stringClass] = { 'constructor': true, 'toString': true, 'valueOf': true };
nonEnumProps[errorClass] = nonEnumProps[funcClass] = nonEnumProps[regexpClass] = { 'constructor': true, 'toString': true };
nonEnumProps[objectClass] = { 'constructor': true };
var objectProto = Object.prototype,
hasOwnProperty = objectProto.hasOwnProperty,
objToString = objectProto.toString,
MAX_SAFE_INTEGER = Math.pow(2, 53) - 1;
var support = {};
(function () {
var ctor = function() { this.x = 1; },
props = [];
var keys = Object.keys || (function() {
var hasOwnProperty = Object.prototype.hasOwnProperty,
hasDontEnumBug = !({ toString: null }).propertyIsEnumerable('toString'),
dontEnums = [
'toString',
'toLocaleString',
'valueOf',
'hasOwnProperty',
'isPrototypeOf',
'propertyIsEnumerable',
'constructor'
],
dontEnumsLength = dontEnums.length;
ctor.prototype = { 'valueOf': 1, 'y': 1 };
for (var key in new ctor) { props.push(key); }
for (key in arguments) { }
return function(obj) {
if (typeof obj !== 'object' && (typeof obj !== 'function' || obj === null)) {
throw new TypeError('Object.keys called on non-object');
}
// Detect if `name` or `message` properties of `Error.prototype` are enumerable by default.
support.enumErrorProps = propertyIsEnumerable.call(errorProto, 'message') || propertyIsEnumerable.call(errorProto, 'name');
var result = [], prop, i;
// Detect if `prototype` properties are enumerable by default.
support.enumPrototypes = propertyIsEnumerable.call(ctor, 'prototype');
for (prop in obj) {
if (hasOwnProperty.call(obj, prop)) {
result.push(prop);
}
}
// Detect if `arguments` object indexes are non-enumerable
support.nonEnumArgs = key != 0;
if (hasDontEnumBug) {
for (i = 0; i < dontEnumsLength; i++) {
if (hasOwnProperty.call(obj, dontEnums[i])) {
result.push(dontEnums[i]);
}
}
}
return result;
};
}());
// Detect if properties shadowing those on `Object.prototype` are non-enumerable.
support.nonEnumShadows = !/valueOf/.test(props);
}(1));
function equalObjects(object, other, equalFunc, isLoose, stackA, stackB) {
var objProps = keys(object),
objLength = objProps.length,
othProps = keys(other),
othLength = othProps.length;
var isObject = Rx.internals.isObject = function(value) {
var type = typeof value;
return value && (type == 'function' || type == 'object') || false;
};
function keysIn(object) {
var result = [];
if (!isObject(object)) {
return result;
if (objLength !== othLength && !isLoose) {
return false;
}
var index = objLength, key;
while (index--) {
key = objProps[index];
if (!(isLoose ? key in other : hasOwnProperty.call(other, key))) {
return false;
}
if (support.nonEnumArgs && object.length && isArguments(object)) {
object = slice.call(object);
}
var skipProto = support.enumPrototypes && typeof object == 'function',
skipErrorProps = support.enumErrorProps && (object === errorProto || object instanceof Error);
}
var skipCtor = isLoose;
while (++index < objLength) {
key = objProps[index];
var objValue = object[key],
othValue = other[key],
result;
for (var key in object) {
if (!(skipProto && key == 'prototype') &&
!(skipErrorProps && (key == 'message' || key == 'name'))) {
result.push(key);
}
if (!(result === undefined ? equalFunc(objValue, othValue, isLoose, stackA, stackB) : result)) {
return false;
}
skipCtor || (skipCtor = key === 'constructor');
}
if (!skipCtor) {
var objCtor = object.constructor,
othCtor = other.constructor;
if (support.nonEnumShadows && object !== objectProto) {
var ctor = object.constructor,
index = -1,
length = dontEnumsLength;
if (object === (ctor && ctor.prototype)) {
var className = object === stringProto ? stringClass : object === errorProto ? errorClass : toString.call(object),
nonEnum = nonEnumProps[className];
}
while (++index < length) {
key = dontEnums[index];
if (!(nonEnum && nonEnum[key]) && hasOwnProperty.call(object, key)) {
result.push(key);
}
}
if (objCtor !== othCtor &&
('constructor' in object && 'constructor' in other) &&
!(typeof objCtor === 'function' && objCtor instanceof objCtor &&
typeof othCtor === 'function' && othCtor instanceof othCtor)) {
return false;
}
return result;
}
return true;
}
function internalFor(object, callback, keysFunc) {
var index = -1,
props = keysFunc(object),
length = props.length;
function equalByTag(object, other, tag) {
switch (tag) {
case boolTag:
case dateTag:
return +object === +other;
while (++index < length) {
var key = props[index];
if (callback(object[key], key, object) === false) {
break;
}
}
return object;
}
case errorTag:
return object.name === other.name && object.message === other.message;
function internalForIn(object, callback) {
return internalFor(object, callback, keysIn);
}
case numberTag:
return (object !== +object) ?
other !== +other :
object === +other;
function isNode(value) {
// IE < 9 presents DOM nodes as `Object` objects except they have `toString`
// methods that are `typeof` "string" and still can coerce nodes to strings
return typeof value.toString != 'function' && typeof (value + '') == 'string';
case regexpTag:
case stringTag:
return object === (other + '');
}
return false;
}
var isArguments = function(value) {
return (value && typeof value == 'object') ? toString.call(value) == argsClass : false;
}
var isObject = Rx.internals.isObject = function(value) {
var type = typeof value;
return !!value && (type === 'object' || type === 'function');
};
// fallback for browsers that can't detect `arguments` objects by [[Class]]
if (!supportsArgsClass) {
isArguments = function(value) {
return (value && typeof value == 'object') ? hasOwnProperty.call(value, 'callee') : false;
};
function isObjectLike(value) {
return !!value && typeof value === 'object';
}
function isLength(value) {
return typeof value === 'number' && value > -1 && value % 1 === 0 && value <= MAX_SAFE_INTEGER;
}
var isHostObject = (function() {
try {
Object({ 'toString': 0 } + '');
} catch(e) {
return function() { return false; };
}
var isEqual = Rx.internals.isEqual = function (x, y) {
return deepEquals(x, y, [], []);
return function(value) {
return typeof value.toString !== 'function' && typeof (value + '') === 'string';
};
}());
/** @private
* Used for deep comparison
**/
function deepEquals(a, b, stackA, stackB) {
// exit early for identical values
if (a === b) {
// treat `+0` vs. `-0` as not equal
return a !== 0 || (1 / a == 1 / b);
}
function isTypedArray(value) {
return isObjectLike(value) && isLength(value.length) && !!typedArrayTags[objToString.call(value)];
}
var type = typeof a,
otherType = typeof b;
var isArray = Array.isArray || function(value) {
return isObjectLike(value) && isLength(value.length) && objToString.call(value) === arrayTag;
};
// exit early for unlike primitive values
if (a === a && (a == null || b == null ||
(type != 'function' && type != 'object' && otherType != 'function' && otherType != 'object'))) {
return false;
function arraySome (array, predicate) {
var index = -1,
length = array.length;
while (++index < length) {
if (predicate(array[index], index, array)) {
return true;
}
}
return false;
}
// compare [[Class]] names
var className = toString.call(a),
otherClass = toString.call(b);
function equalArrays(array, other, equalFunc, isLoose, stackA, stackB) {
var index = -1,
arrLength = array.length,
othLength = other.length;
if (className == argsClass) {
className = objectClass;
if (arrLength !== othLength && !(isLoose && othLength > arrLength)) {
return false;
}
// Ignore non-index properties.
while (++index < arrLength) {
var arrValue = array[index],
othValue = other[index],
result;
if (result !== undefined) {
if (result) {
continue;
}
return false;
}
if (otherClass == argsClass) {
otherClass = objectClass;
}
if (className != otherClass) {
// Recursively compare arrays (susceptible to call stack limits).
if (isLoose) {
if (!arraySome(other, function(othValue) {
return arrValue === othValue || equalFunc(arrValue, othValue, isLoose, stackA, stackB);
})) {
return false;
}
} else if (!(arrValue === othValue || equalFunc(arrValue, othValue, isLoose, stackA, stackB))) {
return false;
}
switch (className) {
case boolClass:
case dateClass:
// coerce dates and booleans to numbers, dates to milliseconds and booleans
// to `1` or `0` treating invalid dates coerced to `NaN` as not equal
return +a == +b;
}
return true;
}
case numberClass:
// treat `NaN` vs. `NaN` as equal
return (a != +a) ?
b != +b :
// but treat `-0` vs. `+0` as not equal
(a == 0 ? (1 / a == 1 / b) : a == +b);
function baseIsEqualDeep(object, other, equalFunc, isLoose, stackA, stackB) {
var objIsArr = isArray(object),
othIsArr = isArray(other),
objTag = arrayTag,
othTag = arrayTag;
case regexpClass:
case stringClass:
// coerce regexes to strings (http://es5.github.io/#x15.10.6.4)
// treat string primitives and their corresponding object instances as equal
return a == String(b);
if (!objIsArr) {
objTag = objToString.call(object);
if (objTag === argsTag) {
objTag = objectTag;
} else if (objTag !== objectTag) {
objIsArr = isTypedArray(object);
}
var isArr = className == arrayClass;
if (!isArr) {
}
if (!othIsArr) {
othTag = objToString.call(other);
if (othTag === argsTag) {
othTag = objectTag;
}
}
var objIsObj = objTag === objectTag && !isHostObject(object),
othIsObj = othTag === objectTag && !isHostObject(other),
isSameTag = objTag === othTag;
// exit for functions and DOM nodes
if (className != objectClass || (!support.nodeClass && (isNode(a) || isNode(b)))) {
return false;
}
// in older versions of Opera, `arguments` objects have `Array` constructors
var ctorA = !support.argsObject && isArguments(a) ? Object : a.constructor,
ctorB = !support.argsObject && isArguments(b) ? Object : b.constructor;
if (isSameTag && !(objIsArr || objIsObj)) {
return equalByTag(object, other, objTag);
}
if (!isLoose) {
var objIsWrapped = objIsObj && hasOwnProperty.call(object, '__wrapped__'),
othIsWrapped = othIsObj && hasOwnProperty.call(other, '__wrapped__');
// non `Object` object instances with different constructors are not equal
if (ctorA != ctorB &&
!(hasOwnProperty.call(a, 'constructor') && hasOwnProperty.call(b, 'constructor')) &&
!(isFunction(ctorA) && ctorA instanceof ctorA && isFunction(ctorB) && ctorB instanceof ctorB) &&
('constructor' in a && 'constructor' in b)
) {
return false;
}
if (objIsWrapped || othIsWrapped) {
return equalFunc(objIsWrapped ? object.value() : object, othIsWrapped ? other.value() : other, isLoose, stackA, stackB);
}
// assume cyclic structures are equal
// the algorithm for detecting cyclic structures is adapted from ES 5.1
// section 15.12.3, abstract operation `JO` (http://es5.github.io/#x15.12.3)
var initedStack = !stackA;
stackA || (stackA = []);
stackB || (stackB = []);
}
if (!isSameTag) {
return false;
}
// Assume cyclic values are equal.
// For more information on detecting circular references see https://es5.github.io/#JO.
stackA || (stackA = []);
stackB || (stackB = []);
var length = stackA.length;
while (length--) {
if (stackA[length] == a) {
return stackB[length] == b;
}
var length = stackA.length;
while (length--) {
if (stackA[length] === object) {
return stackB[length] === other;
}
var size = 0;
var result = true;
}
// Add `object` and `other` to the stack of traversed objects.
stackA.push(object);
stackB.push(other);
// add `a` and `b` to the stack of traversed objects
stackA.push(a);
stackB.push(b);
var result = (objIsArr ? equalArrays : equalObjects)(object, other, equalFunc, isLoose, stackA, stackB);
// recursively compare objects and arrays (susceptible to call stack limits)
if (isArr) {
// compare lengths to determine if a deep comparison is necessary
length = a.length;
size = b.length;
result = size == length;
stackA.pop();
stackB.pop();
if (result) {
// deep compare the contents, ignoring non-numeric properties
while (size--) {
var index = length,
value = b[size];
return result;
}
if (!(result = deepEquals(a[size], value, stackA, stackB))) {
break;
}
}
}
}
else {
// deep compare objects using `forIn`, instead of `forOwn`, to avoid `Object.keys`
// which, in this case, is more costly
internalForIn(b, function(value, key, b) {
if (hasOwnProperty.call(b, key)) {
// count the number of properties.
size++;
// deep compare each property value.
return (result = hasOwnProperty.call(a, key) && deepEquals(a[key], value, stackA, stackB));
}
});
function baseIsEqual(value, other, isLoose, stackA, stackB) {
if (value === other) {
return true;
}
if (value == null || other == null || (!isObject(value) && !isObjectLike(other))) {
return value !== value && other !== other;
}
return baseIsEqualDeep(value, other, baseIsEqual, isLoose, stackA, stackB);
}
if (result) {
// ensure both objects have the same number of properties
internalForIn(a, function(value, key, a) {
if (hasOwnProperty.call(a, key)) {
// `size` will be `-1` if `a` has more properties than `b`
return (result = --size > -1);
}
});
}
}
stackA.pop();
stackB.pop();
var isEqual = Rx.internals.isEqual = function (value, other) {
return baseIsEqual(value, other);
};
return result;
}
var SchedulePeriodicRecursive = Rx.internals.SchedulePeriodicRecursive = (function () {

@@ -487,0 +508,0 @@ function createTick(self) {

2

dist/rx.core.testing.min.js
/* Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.*/
(function(a){function b(a){return a&&a.Object===Object?a:null}var c={"function":!0,object:!0},d=c[typeof exports]&&exports&&!exports.nodeType?exports:null,e=c[typeof module]&&module&&!module.nodeType?module:null,f=b(d&&e&&"object"==typeof global&&global),g=b(c[typeof self]&&self),h=b(c[typeof window]&&window),i=(e&&e.exports===d?d:null,b(c[typeof this]&&this)),j=f||h!==(i&&i.window)&&h||g||i||Function("return this")();"function"==typeof define&&define.amd?define(["./rx.core"],function(b,c){return a(j,c,b)}):"object"==typeof module&&module&&module.exports===d?module.exports=a(j,module.exports,require("./rx.core")):j.Rx=a(j,{},j.Rx)}).call(this,function(a,b,c,d){function e(a){var b=[];if(!_(a))return b;$.nonEnumArgs&&a.length&&aa(a)&&(a=slice.call(a));var c=$.enumPrototypes&&"function"==typeof a,d=$.enumErrorProps&&(a===U||a instanceof Error);for(var e in a)c&&"prototype"==e||d&&("message"==e||"name"==e)||b.push(e);if($.nonEnumShadows&&a!==V){var f=a.constructor,g=-1,h=G;if(a===(f&&f.prototype))var i=a===W?Q:a===U?L:R.call(a),j=Z[i];for(;++g<h;)e=F[g],j&&j[e]||!S.call(a,e)||b.push(e)}return b}function f(a,b,c){for(var d=-1,e=c(a),f=e.length;++d<f;){var g=e[d];if(b(a[g],g,a)===!1)break}return a}function g(a,b){return f(a,b,e)}function h(a){return"function"!=typeof a.toString&&"string"==typeof(a+"")}function i(a,b,c,d){if(a===b)return 0!==a||1/a==1/b;var e=typeof a,f=typeof b;if(a===a&&(null==a||null==b||"function"!=e&&"object"!=e&&"function"!=f&&"object"!=f))return!1;var j=R.call(a),k=R.call(b);if(j==H&&(j=O),k==H&&(k=O),j!=k)return!1;switch(j){case J:case K:return+a==+b;case N:return a!=+a?b!=+b:0==a?1/a==1/b:a==+b;case P:case Q:return a==String(b)}var l=j==I;if(!l){if(j!=O||!$.nodeClass&&(h(a)||h(b)))return!1;var m=!$.argsObject&&aa(a)?Object:a.constructor,n=!$.argsObject&&aa(b)?Object:b.constructor;if(!(m==n||S.call(a,"constructor")&&S.call(b,"constructor")||isFunction(m)&&m instanceof m&&isFunction(n)&&n instanceof n||!("constructor"in a&&"constructor"in b)))return!1}c||(c=[]),d||(d=[]);for(var o=c.length;o--;)if(c[o]==a)return d[o]==b;var p=0,q=!0;if(c.push(a),d.push(b),l){if(o=a.length,p=b.length,q=p==o)for(;p--;){var r=b[p];if(!(q=i(a[p],r,c,d)))break}}else g(b,function(b,e,f){return S.call(f,e)?(p++,q=S.call(a,e)&&i(a[e],b,c,d)):void 0}),q&&g(a,function(a,b,c){return S.call(c,b)?q=--p>-1:void 0});return c.pop(),d.pop(),q}function j(a){this.predicate=a}function k(a){this.predicate=a}function l(a,b){var c=this;this.scheduler=a,this.messages=b,this.subscriptions=[],this.observers=[];for(var d=0,e=this.messages.length;e>d;d++){var f=this.messages[d],g=f.value;!function(b){a.scheduleAbsolute(null,f.time,function(){for(var a=c.observers.slice(0),d=0,e=a.length;e>d;d++)b.accept(a[d]);return q})}(g)}}var m,n=c.Observer,o=c.Observable,p=c.Disposable,q=p.empty,r=p.create,s=c.CompositeDisposable,t=c.SingleAssignmentDisposable,u=c.Scheduler,v=c.internals.ScheduledItem,w=c.internals.SchedulePeriodicRecursive,x=c.internals.PriorityQueue,y=c.internals.inherits,z=c.helpers.notImplemented,A=c.helpers.defaultComparer=function(a,b){return ba(a,b)},B=c.Notification=function(){function a(){}return a.prototype._accept=function(a,b,c){throw new NotImplementedError},a.prototype._acceptObservable=function(a,b,c){throw new NotImplementedError},a.prototype.accept=function(a,b,c){return a&&"object"==typeof a?this._acceptObservable(a):this._accept(a,b,c)},a.prototype.toObservable=function(a){var b=this;return isScheduler(a)||(a=immediateScheduler),new AnonymousObservable(function(c){return a.schedule(b,function(a,b){b._acceptObservable(c),"N"===b.kind&&c.onCompleted()})})},a}(),C=function(a){function b(a){this.value=a,this.kind="N"}return y(b,a),b.prototype._accept=function(a){return a(this.value)},b.prototype._acceptObservable=function(a){return a.onNext(this.value)},b.prototype.toString=function(){return"OnNext("+this.value+")"},b}(B),D=function(a){function b(a){this.error=a,this.kind="E"}return y(b,a),b.prototype._accept=function(a,b){return b(this.error)},b.prototype._acceptObservable=function(a){return a.onError(this.error)},b.prototype.toString=function(){return"OnError("+this.error+")"},b}(B),E=function(a){function b(){this.kind="C"}return y(b,a),b.prototype._accept=function(a,b,c){return c()},b.prototype._acceptObservable=function(a){return a.onCompleted()},b.prototype.toString=function(){return"OnCompleted()"},b}(B),F=(B.createOnNext=function(a){return new C(a)},B.createOnError=function(a){return new D(a)},B.createOnCompleted=function(){return new E},["toString","toLocaleString","valueOf","hasOwnProperty","isPrototypeOf","propertyIsEnumerable","constructor"]),G=F.length,H="[object Arguments]",I="[object Array]",J="[object Boolean]",K="[object Date]",L="[object Error]",M="[object Function]",N="[object Number]",O="[object Object]",P="[object RegExp]",Q="[object String]",R=Object.prototype.toString,S=Object.prototype.hasOwnProperty,T=R.call(arguments)==H,U=Error.prototype,V=Object.prototype,W=String.prototype,X=V.propertyIsEnumerable;try{m=!(R.call(document)==O&&!({toString:0}+""))}catch(Y){m=!0}var Z={};Z[I]=Z[K]=Z[N]={constructor:!0,toLocaleString:!0,toString:!0,valueOf:!0},Z[J]=Z[Q]={constructor:!0,toString:!0,valueOf:!0},Z[L]=Z[M]=Z[P]={constructor:!0,toString:!0},Z[O]={constructor:!0};var $={};!function(){var a=function(){this.x=1},b=[];a.prototype={valueOf:1,y:1};for(var c in new a)b.push(c);for(c in arguments);$.enumErrorProps=X.call(U,"message")||X.call(U,"name"),$.enumPrototypes=X.call(a,"prototype"),$.nonEnumArgs=0!=c,$.nonEnumShadows=!/valueOf/.test(b)}(1);var _=c.internals.isObject=function(a){var b=typeof a;return a&&("function"==b||"object"==b)||!1},aa=function(a){return a&&"object"==typeof a?R.call(a)==H:!1};T||(aa=function(a){return a&&"object"==typeof a?S.call(a,"callee"):!1});var ba=c.internals.isEqual=function(a,b){return i(a,b,[],[])},w=c.internals.SchedulePeriodicRecursive=function(){function a(a){return function(b,c){c(0,a._period);var d=tryCatch(a._action)(a._state);d===errorObj&&(a._cancel.dispose(),thrower(d.e)),a._state=d}}function b(a,b,c,d){this._scheduler=a,this._state=b,this._period=c,this._action=d}return b.prototype.start=function(){var b=new t;return this._cancel=b,b.setDisposable(this._scheduler.scheduleRecursiveFuture(0,this._period,a(this))),b},b}(),ca=c.VirtualTimeScheduler=function(a){function b(b,c){this.clock=b,this.comparer=c,this.isEnabled=!1,this.queue=new x(1024),a.call(this)}y(b,a);var c=b.prototype;return c.now=function(){return this.toAbsoluteTime(this.clock)},c.schedule=function(a,b){return this.scheduleAbsolute(a,this.clock,b)},c.scheduleFuture=function(a,b,c){var d=b instanceof Date?this.toRelativeTime(b-this.now()):this.toRelativeTime(b);return this.scheduleRelative(a,d,c)},c.add=z,c.toAbsoluteTime=z,c.toRelativeTime=z,c.schedulePeriodic=function(a,b,c){var d=new w(this,a,b,c);return d.start()},c.scheduleRelative=function(a,b,c){var d=this.add(this.clock,b);return this.scheduleAbsolute(a,d,c)},c.start=function(){if(!this.isEnabled){this.isEnabled=!0;do{var a=this.getNext();null!==a?(this.comparer(a.dueTime,this.clock)>0&&(this.clock=a.dueTime),a.invoke()):this.isEnabled=!1}while(this.isEnabled)}},c.stop=function(){this.isEnabled=!1},c.advanceTo=function(a){var b=this.comparer(this.clock,a);if(this.comparer(this.clock,a)>0)throw new ArgumentOutOfRangeError;if(0!==b&&!this.isEnabled){this.isEnabled=!0;do{var c=this.getNext();null!==c&&this.comparer(c.dueTime,a)<=0?(this.comparer(c.dueTime,this.clock)>0&&(this.clock=c.dueTime),c.invoke()):this.isEnabled=!1}while(this.isEnabled);this.clock=a}},c.advanceBy=function(a){var b=this.add(this.clock,a),c=this.comparer(this.clock,b);if(c>0)throw new ArgumentOutOfRangeError;0!==c&&this.advanceTo(b)},c.sleep=function(a){var b=this.add(this.clock,a);if(this.comparer(this.clock,b)>=0)throw new ArgumentOutOfRangeError;this.clock=b},c.getNext=function(){for(;this.queue.length>0;){var a=this.queue.peek();if(!a.isCancelled())return a;this.queue.dequeue()}return null},c.scheduleAbsolute=function(a,b,c){function d(a,b){return e.queue.remove(f),c(a,b)}var e=this,f=new v(this,a,d,b,this.comparer);return this.queue.enqueue(f),f.disposable},b}(u);j.prototype.equals=function(a){return a===this?!0:null==a?!1:"N"!==a.kind?!1:this.predicate(a.value)},k.prototype.equals=function(a){return a===this?!0:null==a?!1:"E"!==a.kind?!1:this.predicate(a.error)};var da=c.ReactiveTest={created:100,subscribed:200,disposed:1e3,onNext:function(a,b){return"function"==typeof b?new ea(a,new j(b)):new ea(a,B.createOnNext(b))},onError:function(a,b){return"function"==typeof b?new ea(a,new k(b)):new ea(a,B.createOnError(b))},onCompleted:function(a){return new ea(a,B.createOnCompleted())},subscribe:function(a,b){return new fa(a,b)}},ea=c.Recorded=function(a,b,c){this.time=a,this.value=b,this.comparer=c||A};ea.prototype.equals=function(a){return this.time===a.time&&this.comparer(this.value,a.value)},ea.prototype.toString=function(){return this.value.toString()+"@"+this.time};var fa=c.Subscription=function(a,b){this.subscribe=a,this.unsubscribe=b||Number.MAX_VALUE};fa.prototype.equals=function(a){return this.subscribe===a.subscribe&&this.unsubscribe===a.unsubscribe},fa.prototype.toString=function(){return"("+this.subscribe+", "+(this.unsubscribe===Number.MAX_VALUE?"Infinite":this.unsubscribe)+")"};var ga=c.MockDisposable=function(a){this.scheduler=a,this.disposes=[],this.disposes.push(this.scheduler.clock)};ga.prototype.dispose=function(){this.disposes.push(this.scheduler.clock)};var ha=function(a){function b(b){a.call(this),this.scheduler=b,this.messages=[]}y(b,a);var c=b.prototype;return c.onNext=function(a){this.messages.push(new ea(this.scheduler.clock,B.createOnNext(a)))},c.onError=function(a){this.messages.push(new ea(this.scheduler.clock,B.createOnError(a)))},c.onCompleted=function(){this.messages.push(new ea(this.scheduler.clock,B.createOnCompleted()))},b}(n);l.prototype.then=function(a,b){var e=this;this.subscriptions.push(new fa(this.scheduler.clock));var f,g=this.subscriptions.length-1,h=c.Observer.create(function(b){var i=a(b);if(i&&"function"==typeof i.then)f=i;else{var j=e.scheduler.clock;f=new l(e.scheduler,[c.ReactiveTest.onNext(j,d),c.ReactiveTest.onCompleted(j)])}var k=e.observers.indexOf(h);e.observers.splice(k,1),e.subscriptions[g]=new fa(e.subscriptions[g].subscribe,e.scheduler.clock)},function(a){b(a);var c=e.observers.indexOf(h);e.observers.splice(c,1),e.subscriptions[g]=new fa(e.subscriptions[g].subscribe,e.scheduler.clock)});return this.observers.push(h),f||new l(this.scheduler,this.messages)};var ia=function(a){function b(b,c){a.call(this);var d,e,f=this;this.scheduler=b,this.messages=c,this.subscriptions=[],this.observers=[];for(var g=0,h=this.messages.length;h>g;g++)d=this.messages[g],e=d.value,function(a){b.scheduleAbsolute(null,d.time,function(){for(var b=f.observers.slice(0),c=0,d=b.length;d>c;c++)a.accept(b[c]);return q})}(e)}return y(b,a),b.prototype._subscribe=function(a){var b=this;this.observers.push(a),this.subscriptions.push(new fa(this.scheduler.clock));var c=this.subscriptions.length-1;return r(function(){var d=b.observers.indexOf(a);b.observers.splice(d,1),b.subscriptions[c]=new fa(b.subscriptions[c].subscribe,b.scheduler.clock)})},b}(o),ja=function(a){function b(b,c){a.call(this),this.scheduler=b,this.messages=c,this.subscriptions=[]}return y(b,a),b.prototype._subscribe=function(a){var b,c,d=this;this.subscriptions.push(new fa(this.scheduler.clock));for(var e=this.subscriptions.length-1,f=new s,g=0,h=this.messages.length;h>g;g++)b=this.messages[g],c=b.value,function(c){f.add(d.scheduler.scheduleRelative(null,b.time,function(){return c.accept(a),q}))}(c);return r(function(){d.subscriptions[e]=new fa(d.subscriptions[e].subscribe,d.scheduler.clock),f.dispose()})},b}(o);return c.TestScheduler=function(a){function b(a,b){return a>b?1:b>a?-1:0}function d(){a.call(this,0,b)}return y(d,a),d.prototype.scheduleAbsolute=function(b,c,d){return c<=this.clock&&(c=this.clock+1),a.prototype.scheduleAbsolute.call(this,b,c,d)},d.prototype.add=function(a,b){return a+b},d.prototype.toAbsoluteTime=function(a){return new Date(a).getTime()},d.prototype.toRelativeTime=function(a){return a},d.prototype.startScheduler=function(a,b){b||(b={}),null==b.created&&(b.created=da.created),null==b.subscribed&&(b.subscribed=da.subscribed),null==b.disposed&&(b.disposed=da.disposed);var c,d,e=this.createObserver();return this.scheduleAbsolute(null,b.created,function(){return c=a(),q}),this.scheduleAbsolute(null,b.subscribed,function(){return d=c.subscribe(e),q}),this.scheduleAbsolute(null,b.disposed,function(){return d.dispose(),q}),this.start(),e},d.prototype.createHotObservable=function(){var a,b=arguments.length;if(Array.isArray(arguments[0]))a=arguments[0];else{a=new Array(b);for(var c=0;b>c;c++)a[c]=arguments[c]}return new ia(this,a)},d.prototype.createColdObservable=function(){var a,b=arguments.length;if(Array.isArray(arguments[0]))a=arguments[0];else{a=new Array(b);for(var c=0;b>c;c++)a[c]=arguments[c]}return new ja(this,a)},d.prototype.createResolvedPromise=function(a,b){return new l(this,[c.ReactiveTest.onNext(a,b),c.ReactiveTest.onCompleted(a)])},d.prototype.createRejectedPromise=function(a,b){return new l(this,[c.ReactiveTest.onError(a,b)])},d.prototype.createObserver=function(){return new ha(this)},d}(ca),c});
(function(a){function b(a){return a&&a.Object===Object?a:null}var c={"function":!0,object:!0},d=c[typeof exports]&&exports&&!exports.nodeType?exports:null,e=c[typeof module]&&module&&!module.nodeType?module:null,f=b(d&&e&&"object"==typeof global&&global),g=b(c[typeof self]&&self),h=b(c[typeof window]&&window),i=(e&&e.exports===d?d:null,b(c[typeof this]&&this)),j=f||h!==(i&&i.window)&&h||g||i||Function("return this")();"function"==typeof define&&define.amd?define(["./rx.core"],function(b,c){return a(j,c,b)}):"object"==typeof module&&module&&module.exports===d?module.exports=a(j,module.exports,require("./rx.core")):j.Rx=a(j,{},j.Rx)}).call(this,function(a,b,c,d){function e(a,b,c,e,f,g){var h=ja(a),i=h.length,j=ja(b),k=j.length;if(i!==k&&!e)return!1;for(var l,m=i;m--;)if(l=h[m],!(e?l in b:ga.call(b,l)))return!1;for(var n=e;++m<i;){l=h[m];var o,p=a[l],q=b[l];if(!(o===d?c(p,q,e,f,g):o))return!1;n||(n="constructor"===l)}if(!n){var r=a.constructor,s=b.constructor;if(r!==s&&"constructor"in a&&"constructor"in b&&!("function"==typeof r&&r instanceof r&&"function"==typeof s&&s instanceof s))return!1}return!0}function f(a,b,c){switch(c){case L:case M:return+a===+b;case N:return a.name===b.name&&a.message===b.message;case Q:return a!==+a?b!==+b:a===+b;case S:case U:return a===b+""}return!1}function g(a){return!!a&&"object"==typeof a}function h(a){return"number"==typeof a&&a>-1&&a%1===0&&ia>=a}function i(a){return g(a)&&h(a.length)&&!!ea[ha.call(a)]}function j(a,b){for(var c=-1,d=a.length;++c<d;)if(b(a[c],c,a))return!0;return!1}function k(a,b,c,e,f,g){var h=-1,i=a.length,k=b.length;if(i!==k&&!(e&&k>i))return!1;for(;++h<i;){var l,m=a[h],n=b[h];if(l!==d){if(l)continue;return!1}if(e){if(!j(b,function(a){return m===a||c(m,a,e,f,g)}))return!1}else if(m!==n&&!c(m,n,e,f,g))return!1}return!0}function l(a,b,c,d,g,h){var j=ma(a),l=ma(b),m=K,n=K;j||(m=ha.call(a),m===J?m=R:m!==R&&(j=i(a))),l||(n=ha.call(b),n===J&&(n=R));var o=m===R&&!la(a),p=n===R&&!la(b),q=m===n;if(q&&!j&&!o)return f(a,b,m);if(!d){var r=o&&ga.call(a,"__wrapped__"),s=p&&ga.call(b,"__wrapped__");if(r||s)return c(r?a.value():a,s?b.value():b,d,g,h)}if(!q)return!1;g||(g=[]),h||(h=[]);for(var t=g.length;t--;)if(g[t]===a)return h[t]===b;g.push(a),h.push(b);var u=(j?k:e)(a,b,c,d,g,h);return g.pop(),h.pop(),u}function m(a,b,c,d,e){return a===b?!0:null==a||null==b||!ka(a)&&!g(b)?a!==a&&b!==b:l(a,b,m,c,d,e)}function n(a){this.predicate=a}function o(a){this.predicate=a}function p(a,b){var c=this;this.scheduler=a,this.messages=b,this.subscriptions=[],this.observers=[];for(var d=0,e=this.messages.length;e>d;d++){var f=this.messages[d],g=f.value;!function(b){a.scheduleAbsolute(null,f.time,function(){for(var a=c.observers.slice(0),d=0,e=a.length;e>d;d++)b.accept(a[d]);return t})}(g)}}var q=c.Observer,r=c.Observable,s=c.Disposable,t=s.empty,u=s.create,v=c.CompositeDisposable,w=c.SingleAssignmentDisposable,x=c.Scheduler,y=c.internals.ScheduledItem,z=c.internals.SchedulePeriodicRecursive,A=c.internals.PriorityQueue,B=c.internals.inherits,C=c.helpers.notImplemented,D=c.helpers.defaultComparer=function(a,b){return na(a,b)},E=c.Notification=function(){function a(){}return a.prototype._accept=function(a,b,c){throw new NotImplementedError},a.prototype._acceptObserver=function(a,b,c){throw new NotImplementedError},a.prototype.accept=function(a,b,c){return a&&"object"==typeof a?this._acceptObserver(a):this._accept(a,b,c)},a.prototype.toObservable=function(a){var b=this;return isScheduler(a)||(a=immediateScheduler),new AnonymousObservable(function(c){return a.schedule(b,function(a,b){b._acceptObserver(c),"N"===b.kind&&c.onCompleted()})})},a}(),F=function(a){function b(a){this.value=a,this.kind="N"}return B(b,a),b.prototype._accept=function(a){return a(this.value)},b.prototype._acceptObserver=function(a){return a.onNext(this.value)},b.prototype.toString=function(){return"OnNext("+this.value+")"},b}(E),G=function(a){function b(a){this.error=a,this.kind="E"}return B(b,a),b.prototype._accept=function(a,b){return b(this.error)},b.prototype._acceptObserver=function(a){return a.onError(this.error)},b.prototype.toString=function(){return"OnError("+this.error+")"},b}(E),H=function(a){function b(){this.kind="C"}return B(b,a),b.prototype._accept=function(a,b,c){return c()},b.prototype._acceptObserver=function(a){return a.onCompleted()},b.prototype.toString=function(){return"OnCompleted()"},b}(E),I=(E.createOnNext=function(a){return new F(a)},E.createOnError=function(a){return new G(a)},E.createOnCompleted=function(){return new H},["toString","toLocaleString","valueOf","hasOwnProperty","isPrototypeOf","propertyIsEnumerable","constructor"]),J=(I.length,"[object Arguments]"),K="[object Array]",L="[object Boolean]",M="[object Date]",N="[object Error]",O="[object Function]",P="[object Map]",Q="[object Number]",R="[object Object]",S="[object RegExp]",T="[object Set]",U="[object String]",V="[object WeakMap]",W="[object ArrayBuffer]",X="[object Float32Array]",Y="[object Float64Array]",Z="[object Int8Array]",$="[object Int16Array]",_="[object Int32Array]",aa="[object Uint8Array]",ba="[object Uint8ClampedArray]",ca="[object Uint16Array]",da="[object Uint32Array]",ea={};ea[X]=ea[Y]=ea[Z]=ea[$]=ea[_]=ea[aa]=ea[ba]=ea[ca]=ea[da]=!0,ea[J]=ea[K]=ea[W]=ea[L]=ea[M]=ea[N]=ea[O]=ea[P]=ea[Q]=ea[R]=ea[S]=ea[T]=ea[U]=ea[V]=!1;var fa=Object.prototype,ga=fa.hasOwnProperty,ha=fa.toString,ia=Math.pow(2,53)-1,ja=Object.keys||function(){var a=Object.prototype.hasOwnProperty,b=!{toString:null}.propertyIsEnumerable("toString"),c=["toString","toLocaleString","valueOf","hasOwnProperty","isPrototypeOf","propertyIsEnumerable","constructor"],d=c.length;return function(e){if("object"!=typeof e&&("function"!=typeof e||null===e))throw new TypeError("Object.keys called on non-object");var f,g,h=[];for(f in e)a.call(e,f)&&h.push(f);if(b)for(g=0;d>g;g++)a.call(e,c[g])&&h.push(c[g]);return h}}(),ka=c.internals.isObject=function(a){var b=typeof a;return!!a&&("object"===b||"function"===b)},la=function(){try{Object({toString:0}+"")}catch(a){return function(){return!1}}return function(a){return"function"!=typeof a.toString&&"string"==typeof(a+"")}}(),ma=Array.isArray||function(a){return g(a)&&h(a.length)&&ha.call(a)===K},na=c.internals.isEqual=function(a,b){return m(a,b)},z=c.internals.SchedulePeriodicRecursive=function(){function a(a){return function(b,c){c(0,a._period);var d=tryCatch(a._action)(a._state);d===errorObj&&(a._cancel.dispose(),thrower(d.e)),a._state=d}}function b(a,b,c,d){this._scheduler=a,this._state=b,this._period=c,this._action=d}return b.prototype.start=function(){var b=new w;return this._cancel=b,b.setDisposable(this._scheduler.scheduleRecursiveFuture(0,this._period,a(this))),b},b}(),oa=c.VirtualTimeScheduler=function(a){function b(b,c){this.clock=b,this.comparer=c,this.isEnabled=!1,this.queue=new A(1024),a.call(this)}B(b,a);var c=b.prototype;return c.now=function(){return this.toAbsoluteTime(this.clock)},c.schedule=function(a,b){return this.scheduleAbsolute(a,this.clock,b)},c.scheduleFuture=function(a,b,c){var d=b instanceof Date?this.toRelativeTime(b-this.now()):this.toRelativeTime(b);return this.scheduleRelative(a,d,c)},c.add=C,c.toAbsoluteTime=C,c.toRelativeTime=C,c.schedulePeriodic=function(a,b,c){var d=new z(this,a,b,c);return d.start()},c.scheduleRelative=function(a,b,c){var d=this.add(this.clock,b);return this.scheduleAbsolute(a,d,c)},c.start=function(){if(!this.isEnabled){this.isEnabled=!0;do{var a=this.getNext();null!==a?(this.comparer(a.dueTime,this.clock)>0&&(this.clock=a.dueTime),a.invoke()):this.isEnabled=!1}while(this.isEnabled)}},c.stop=function(){this.isEnabled=!1},c.advanceTo=function(a){var b=this.comparer(this.clock,a);if(this.comparer(this.clock,a)>0)throw new ArgumentOutOfRangeError;if(0!==b&&!this.isEnabled){this.isEnabled=!0;do{var c=this.getNext();null!==c&&this.comparer(c.dueTime,a)<=0?(this.comparer(c.dueTime,this.clock)>0&&(this.clock=c.dueTime),c.invoke()):this.isEnabled=!1}while(this.isEnabled);this.clock=a}},c.advanceBy=function(a){var b=this.add(this.clock,a),c=this.comparer(this.clock,b);if(c>0)throw new ArgumentOutOfRangeError;0!==c&&this.advanceTo(b)},c.sleep=function(a){var b=this.add(this.clock,a);if(this.comparer(this.clock,b)>=0)throw new ArgumentOutOfRangeError;this.clock=b},c.getNext=function(){for(;this.queue.length>0;){var a=this.queue.peek();if(!a.isCancelled())return a;this.queue.dequeue()}return null},c.scheduleAbsolute=function(a,b,c){function d(a,b){return e.queue.remove(f),c(a,b)}var e=this,f=new y(this,a,d,b,this.comparer);return this.queue.enqueue(f),f.disposable},b}(x);n.prototype.equals=function(a){return a===this?!0:null==a?!1:"N"!==a.kind?!1:this.predicate(a.value)},o.prototype.equals=function(a){return a===this?!0:null==a?!1:"E"!==a.kind?!1:this.predicate(a.error)};var pa=c.ReactiveTest={created:100,subscribed:200,disposed:1e3,onNext:function(a,b){return"function"==typeof b?new qa(a,new n(b)):new qa(a,E.createOnNext(b))},onError:function(a,b){return"function"==typeof b?new qa(a,new o(b)):new qa(a,E.createOnError(b))},onCompleted:function(a){return new qa(a,E.createOnCompleted())},subscribe:function(a,b){return new ra(a,b)}},qa=c.Recorded=function(a,b,c){this.time=a,this.value=b,this.comparer=c||D};qa.prototype.equals=function(a){return this.time===a.time&&this.comparer(this.value,a.value)},qa.prototype.toString=function(){return this.value.toString()+"@"+this.time};var ra=c.Subscription=function(a,b){this.subscribe=a,this.unsubscribe=b||Number.MAX_VALUE};ra.prototype.equals=function(a){return this.subscribe===a.subscribe&&this.unsubscribe===a.unsubscribe},ra.prototype.toString=function(){return"("+this.subscribe+", "+(this.unsubscribe===Number.MAX_VALUE?"Infinite":this.unsubscribe)+")"};var sa=c.MockDisposable=function(a){this.scheduler=a,this.disposes=[],this.disposes.push(this.scheduler.clock)};sa.prototype.dispose=function(){this.disposes.push(this.scheduler.clock)};var ta=function(a){function b(b){a.call(this),this.scheduler=b,this.messages=[]}B(b,a);var c=b.prototype;return c.onNext=function(a){this.messages.push(new qa(this.scheduler.clock,E.createOnNext(a)))},c.onError=function(a){this.messages.push(new qa(this.scheduler.clock,E.createOnError(a)))},c.onCompleted=function(){this.messages.push(new qa(this.scheduler.clock,E.createOnCompleted()))},b}(q);p.prototype.then=function(a,b){var e=this;this.subscriptions.push(new ra(this.scheduler.clock));var f,g=this.subscriptions.length-1,h=c.Observer.create(function(b){var i=a(b);if(i&&"function"==typeof i.then)f=i;else{var j=e.scheduler.clock;f=new p(e.scheduler,[c.ReactiveTest.onNext(j,d),c.ReactiveTest.onCompleted(j)])}var k=e.observers.indexOf(h);e.observers.splice(k,1),e.subscriptions[g]=new ra(e.subscriptions[g].subscribe,e.scheduler.clock)},function(a){b(a);var c=e.observers.indexOf(h);e.observers.splice(c,1),e.subscriptions[g]=new ra(e.subscriptions[g].subscribe,e.scheduler.clock)});return this.observers.push(h),f||new p(this.scheduler,this.messages)};var ua=function(a){function b(b,c){a.call(this);var d,e,f=this;this.scheduler=b,this.messages=c,this.subscriptions=[],this.observers=[];for(var g=0,h=this.messages.length;h>g;g++)d=this.messages[g],e=d.value,function(a){b.scheduleAbsolute(null,d.time,function(){for(var b=f.observers.slice(0),c=0,d=b.length;d>c;c++)a.accept(b[c]);return t})}(e)}return B(b,a),b.prototype._subscribe=function(a){var b=this;this.observers.push(a),this.subscriptions.push(new ra(this.scheduler.clock));var c=this.subscriptions.length-1;return u(function(){var d=b.observers.indexOf(a);b.observers.splice(d,1),b.subscriptions[c]=new ra(b.subscriptions[c].subscribe,b.scheduler.clock)})},b}(r),va=function(a){function b(b,c){a.call(this),this.scheduler=b,this.messages=c,this.subscriptions=[]}return B(b,a),b.prototype._subscribe=function(a){var b,c,d=this;this.subscriptions.push(new ra(this.scheduler.clock));for(var e=this.subscriptions.length-1,f=new v,g=0,h=this.messages.length;h>g;g++)b=this.messages[g],c=b.value,function(c){f.add(d.scheduler.scheduleRelative(null,b.time,function(){return c.accept(a),t}))}(c);return u(function(){d.subscriptions[e]=new ra(d.subscriptions[e].subscribe,d.scheduler.clock),f.dispose()})},b}(r);return c.TestScheduler=function(a){function b(a,b){return a>b?1:b>a?-1:0}function d(){a.call(this,0,b)}return B(d,a),d.prototype.scheduleAbsolute=function(b,c,d){return c<=this.clock&&(c=this.clock+1),a.prototype.scheduleAbsolute.call(this,b,c,d)},d.prototype.add=function(a,b){return a+b},d.prototype.toAbsoluteTime=function(a){return new Date(a).getTime()},d.prototype.toRelativeTime=function(a){return a},d.prototype.startScheduler=function(a,b){b||(b={}),null==b.created&&(b.created=pa.created),null==b.subscribed&&(b.subscribed=pa.subscribed),null==b.disposed&&(b.disposed=pa.disposed);var c,d,e=this.createObserver();return this.scheduleAbsolute(null,b.created,function(){return c=a(),t}),this.scheduleAbsolute(null,b.subscribed,function(){return d=c.subscribe(e),t}),this.scheduleAbsolute(null,b.disposed,function(){return d.dispose(),t}),this.start(),e},d.prototype.createHotObservable=function(){var a,b=arguments.length;if(Array.isArray(arguments[0]))a=arguments[0];else{a=new Array(b);for(var c=0;b>c;c++)a[c]=arguments[c]}return new ua(this,a)},d.prototype.createColdObservable=function(){var a,b=arguments.length;if(Array.isArray(arguments[0]))a=arguments[0];else{a=new Array(b);for(var c=0;b>c;c++)a[c]=arguments[c]}return new va(this,a)},d.prototype.createResolvedPromise=function(a,b){return new p(this,[c.ReactiveTest.onNext(a,b),c.ReactiveTest.onCompleted(a)])},d.prototype.createRejectedPromise=function(a,b){return new p(this,[c.ReactiveTest.onError(a,b)])},d.prototype.createObserver=function(){return new ta(this)},d}(oa),c});
//# sourceMappingURL=rx.core.testing.map

15

dist/rx.experimental.js

@@ -511,9 +511,10 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

SwitchFirstObservable.prototype.subscribeCore = function (o) {
var m = new SingleAssignmentDisposable(), g = new CompositeDisposable(),
state = {
hasCurrent: false,
isStopped: false,
o: o,
g: g
};
var m = new SingleAssignmentDisposable(),
g = new CompositeDisposable(),
state = {
hasCurrent: false,
isStopped: false,
o: o,
g: g
};

@@ -520,0 +521,0 @@ g.add(m);

2

dist/rx.lite.extras.compat.js

@@ -791,3 +791,3 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

hasObservable = true;
observable = source.finally(function() { hasObservable = false; }).publish().refCount();
observable = source['finally'](function() { hasObservable = false; }).publish().refCount();
}

@@ -794,0 +794,0 @@ return observable;

2

dist/rx.lite.extras.js

@@ -791,3 +791,3 @@ // Copyright (c) Microsoft, All rights reserved. See License.txt in the project root for license information.

hasObservable = true;
observable = source.finally(function() { hasObservable = false; }).publish().refCount();
observable = source['finally'](function() { hasObservable = false; }).publish().refCount();
}

@@ -794,0 +794,0 @@ return observable;

2

package.json

@@ -5,3 +5,3 @@ {

"description": "Library for composing asynchronous and event-based operations in JavaScript",
"version": "4.0.6",
"version": "4.0.7",
"homepage": "https://github.com/Reactive-Extensions/RxJS",

@@ -8,0 +8,0 @@ "author": {

40

readme.md

@@ -1,7 +0,7 @@

[![Build Status](https://travis-ci.org/Reactive-Extensions/RxJS.png)](https://travis-ci.org/Reactive-Extensions/RxJS)
[![GitHub version](http://img.shields.io/github/tag/reactive-extensions/rxjs.svg)](https://github.com/Reactive-Extensions/RxJS)
[![NPM version](http://img.shields.io/npm/v/rx.svg)](https://npmjs.org/package/rx)
[![Downloads](http://img.shields.io/npm/dm/rx.svg)](https://npmjs.org/package/rx)
[![Build Status](https://travis-ci.org/Reactive-Extensions/RxJS.svg)](https://travis-ci.org/Reactive-Extensions/RxJS)
[![GitHub version](https://img.shields.io/github/tag/reactive-extensions/rxjs.svg)](https://github.com/Reactive-Extensions/RxJS)
[![NPM version](https://img.shields.io/npm/v/rx.svg)](https://www.npmjs.com/package/rx)
[![Downloads](https://img.shields.io/npm/dm/rx.svg)](https://www.npmjs.com/package/rx)
[![Bower](https://img.shields.io/bower/v/rxjs.svg)](http://bower.io/search/?q=rxjs)
[![NuGet](http://img.shields.io/nuget/v/RxJS-All.svg)](http://www.nuget.org/packages/RxJS-All/)
[![NuGet](https://img.shields.io/nuget/v/RxJS-All.svg)](http://www.nuget.org/packages/RxJS-All/)
[![Join the chat at https://gitter.im/Reactive-Extensions/RxJS](https://badges.gitter.im/Join%20Chat.svg)](https://gitter.im/Reactive-Extensions/RxJS?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge&utm_content=badge)

@@ -21,7 +21,7 @@

# The Reactive Extensions for JavaScript (RxJS) <sup>3.0</sup>... #
# The Reactive Extensions for JavaScript (RxJS) <sup>4.0</sup>... #
*...is a set of libraries to compose asynchronous and event-based programs using observable collections and [Array#extras](http://blogs.msdn.com/b/ie/archive/2010/12/13/ecmascript-5-part-2-array-extras.aspx) style composition in JavaScript*
The project is actively developed by [Microsoft Open Technologies, Inc.](http://msopentech.com/), in collaboration with a community of open source developers.
The project is actively developed by [Microsoft Open Technologies, Inc.](https://msopentech.com/), in collaboration with a community of open source developers.

@@ -163,3 +163,3 @@ ## The Need to go Reactive ##

return $.ajax({
url: 'http://en.wikipedia.org/w/api.php',
url: 'https://en.wikipedia.org/w/api.php',
dataType: 'jsonp',

@@ -218,7 +218,7 @@ data: {

- Contact us
- [Tech Blog](http://blogs.msdn.com/b/rxteam)
- [Tech Blog](http://blogs.msdn.com/b/rxteam/)
- [Twitter @ReactiveX](https://twitter.com/ReactiveX)
- [Twitter @OpenAtMicrosoft](http://twitter.com/OpenAtMicrosoft)
- [Twitter @OpenAtMicrosoft](https://twitter.com/OpenAtMicrosoft)
- [StackOverflow rxjs](http://stackoverflow.com/questions/tagged/rxjs)
- [Slack](http://reactivex.slack.com)
- [Slack](https://reactivex.slack.com/)

@@ -238,7 +238,7 @@ - Tutorials

- [Rx Marbles](http://rxmarbles.com/)
- [RxJS GitBook](http://xgrommx.github.io/rx-book/)
- [RxJS GitBook](http://xgrommx.github.io/rx-book//)
- [Intro to Rx](http://introtorx.com/)
- [101 Rx Samples Wiki](http://rxwiki.wikidot.com/101samples)
- [RxJS Design Guidelines](https://github.com/Reactive-Extensions/RxJS/tree/master/doc/designguidelines)
- [Visualizing Reactive Streams](http://jaredly.github.io/2015/03/06/visualizing-reactive-streams-hot-and-cold/)
- [Visualizing Reactive Streams](http://jaredforsyth.com/2015/03/06/visualizing-reactive-streams-hot-and-cold/)
- [Your Mouse is a Database](http://queue.acm.org/detail.cfm?id=2169076)

@@ -251,3 +251,3 @@

- Books
- [RxJS](http://xgrommx.github.io/rx-book)
- [RxJS](http://xgrommx.github.io/rx-book/)
- [Intro to Rx](http://www.amazon.com/Introduction-to-Rx-ebook/dp/B008GM3YPM/)

@@ -266,3 +266,3 @@ - [Programming Reactive Extensions and LINQ](http://www.amazon.com/Programming-Reactive-Extensions-Jesse-Liberty/dp/1430237473/)

You can use the [`rx-cli`](https://www.npmjs.org/package/rx-cli) to perform custom builds to create the RxJS you want:
You can use the [`rx-cli`](https://www.npmjs.com/package/rx-cli) to perform custom builds to create the RxJS you want:

@@ -280,3 +280,3 @@ ```bash

### Installing with [NPM](https://npmjs.org/)
### Installing with [NPM](https://www.npmjs.com/)

@@ -304,7 +304,7 @@ ```bash`

```
### Installing All of RxJS via [NuGet](http://nuget.org/)
### Installing All of RxJS via [NuGet](http://www.nuget.org/)
```bash
$ Install-Package RxJS-All
```
### Install individual packages via [NuGet](http://nuget.org/):
### Install individual packages via [NuGet](http://www.nuget.org/):

@@ -377,4 +377,4 @@ Install-Package RxJS-All

- [ReactiveFlux](https://github.com/codesuki/reactive-flux)
- [Thundercats.js](https://github.com/r3dm/thundercats)
- [Flurx](https://github.com/cell303/flurx)
- [Thundercats.js](https://github.com/ThunderCatsJS/thundercats)
- [Flurx](https://github.com/qwtel/flurx)
- [RR](https://github.com/winsonwq/RR)

@@ -381,0 +381,0 @@ - [Ember](http://emberjs.com/)

2

ts/core/linq/observable/debounce.ts

@@ -18,3 +18,3 @@ /// <reference path="../../observable.ts" />

*/
debounce(debounceDurationSelector: (item: T) => ObservableOrPromise<number>): Observable<T>;
debounce(debounceDurationSelector: (item: T) => ObservableOrPromise<any>): Observable<T>;
}

@@ -21,0 +21,0 @@ }

58

ts/core/linq/observable/zip.ts

@@ -68,2 +68,60 @@ /// <reference path="../../observable.ts"/>

}
export interface Observable<T> {
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<T2, TResult>(second: ObservableOrPromise<T2>, resultSelector?: (v1: T, v2: T2) => TResult): Observable<TResult>;
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<T2, T3, TResult>(second: ObservableOrPromise<T2>, third: ObservableOrPromise<T3>, resultSelector?: (v1: T, v2: T2, v3: T3) => TResult): Observable<TResult>;
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<T2, T3, T4, TResult>(second: ObservableOrPromise<T2>, third: ObservableOrPromise<T3>, fourth: ObservableOrPromise<T4>, resultSelector?: (v1: T, v2: T2, v3: T3, v4: T4) => TResult): Observable<TResult>;
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<T2, T3, T4, T5, TResult>(second: ObservableOrPromise<T2>, third: ObservableOrPromise<T3>, fourth: ObservableOrPromise<T4>, fifth: ObservableOrPromise<T5>, resultSelector?: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5) => TResult): Observable<TResult>;
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<T2, T3, T4, T5, T6, TResult>(second: ObservableOrPromise<T2>, third: ObservableOrPromise<T3>, fourth: ObservableOrPromise<T4>, fifth: ObservableOrPromise<T5>, sixth: ObservableOrPromise<T6>, resultSelector?: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5, v6: T6) => TResult): Observable<TResult>;
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<T2, T3, T4, T5, T6, T7, TResult>(second: ObservableOrPromise<T2>, third: ObservableOrPromise<T3>, fourth: ObservableOrPromise<T4>, fifth: ObservableOrPromise<T5>, sixth: ObservableOrPromise<T6>, seventh: ObservableOrPromise<T7>, resultSelector?: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5, v6: T6, v7: T7) => TResult): Observable<TResult>;
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<T2, T3, T4, T5, T6, T7, T8, TResult>(second: ObservableOrPromise<T2>, third: ObservableOrPromise<T3>, fourth: ObservableOrPromise<T4>, fifth: ObservableOrPromise<T5>, sixth: ObservableOrPromise<T6>, seventh: ObservableOrPromise<T7>, eighth: ObservableOrPromise<T8>, resultSelector?: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5, v6: T6, v7: T7, v8: T8) => TResult): Observable<TResult>;
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<T2, T3, T4, T5, T6, T7, T8, T9, TResult>(second: ObservableOrPromise<T2>, third: ObservableOrPromise<T3>, fourth: ObservableOrPromise<T4>, fifth: ObservableOrPromise<T5>, sixth: ObservableOrPromise<T6>, seventh: ObservableOrPromise<T7>, eighth: ObservableOrPromise<T8>, ninth: ObservableOrPromise<T9>, resultSelector?: (v1: T, v2: T2, v3: T3, v4: T4, v5: T5, v6: T6, v7: T7, v8: T8, v9: T9) => TResult): Observable<TResult>;
/**
* Merges the specified observable sequences into one observable sequence by using the selector function whenever all of the observable sequences or an array have produced an element at a corresponding index.
* The last element in the arguments must be a function to invoke for each series of elements at corresponding indexes in the args.
* @returns {Observable} An observable sequence containing the result of combining elements of the args using the specified result selector function.
*/
zip<TOther, TResult>(souces: ObservableOrPromise<TOther>[], resultSelector?: (firstValue: T, ...otherValues: TOther[]) => TResult): Observable<TResult>;
}
}

4

ts/core/notification.ts

@@ -29,3 +29,3 @@ /// <reference path="./disposables/disposable.ts" />

*/
accept<TResult>(onNext: (value: T) => TResult, onError?: (exception: any) => TResult, onCompleted?: () => TResult): TResult;
accept<TResult>(onNext: (value: T) => TResult, onError: (exception: any) => TResult, onCompleted: () => TResult): TResult;

@@ -45,3 +45,3 @@ /**

value: T;
exception: any;
error: any;
}

@@ -48,0 +48,0 @@

2

ts/rx.time.d.ts

@@ -110,3 +110,3 @@ declare module Rx {

*/
debounce(debounceDurationSelector: (item: T) => ObservableOrPromise<number>): Observable<T>;
debounce(debounceDurationSelector: (item: T) => ObservableOrPromise<any>): Observable<T>;
}

@@ -113,0 +113,0 @@

2

ts/rx.time.es6.d.ts

@@ -110,3 +110,3 @@ declare module Rx {

*/
debounce(debounceDurationSelector: (item: T) => ObservableOrPromise<number>): Observable<T>;
debounce(debounceDurationSelector: (item: T) => ObservableOrPromise<any>): Observable<T>;
}

@@ -113,0 +113,0 @@

433

ts/tsconfig.json

@@ -24,218 +24,219 @@ {

"files": [
"./core/abstractobserver.ts",
"./core/anonymousobservable.ts",
"./core/anonymousobserver.ts",
"./core/backpressure/controlled.ts",
"./core/backpressure/pausable.ts",
"./core/backpressure/pausablebuffered.ts",
"./core/backpressure/pauser.ts",
"./core/backpressure/stopandwait.ts",
"./core/backpressure/windowed.ts",
"./core/checkedobserver.ts",
"./core/concurrency/currentthreadscheduler.ts",
"./core/concurrency/defaultscheduler.ts",
"./core/concurrency/historicalscheduler.ts",
"./core/concurrency/immediatescheduler.ts",
"./core/concurrency/scheduleditem.ts",
"./core/concurrency/scheduleperiodicrecursive.ts",
"./core/concurrency/scheduler.periodic.ts",
"./core/concurrency/scheduler.recursive.ts",
"./core/concurrency/scheduler.ts",
"./core/concurrency/scheduler.wrappers.ts",
"./core/concurrency/virtualtimescheduler.ts",
"./core/disposables/booleandisposable.ts",
"./core/disposables/compositedisposable.ts",
"./core/disposables/disposable.ts",
"./core/disposables/refcountdisposable.ts",
"./core/internal/bindcallback.ts",
"./core/internal/errors.ts",
"./core/internal/isequal.ts",
"./core/internal/priorityqueue.ts",
"./core/internal/util.ts",
"./core/joins/pattern.ts",
"./core/joins/plan.ts",
"./core/linq/connectableobservable.ts",
"./core/linq/groupedobservable.ts",
"./core/linq/observable/amb.ts",
"./core/linq/observable/ambproto.ts",
"./core/linq/observable/and.ts",
"./core/linq/observable/asobservable.ts",
"./core/linq/observable/average.ts",
"./core/linq/observable/buffer.ts",
"./core/linq/observable/bufferwithcount.ts",
"./core/linq/observable/bufferwithtime.ts",
"./core/linq/observable/bufferwithtimeorcount.ts",
"./core/linq/observable/case.ts",
"./core/linq/observable/catch.ts",
"./core/linq/observable/catchproto.ts",
"./core/linq/observable/combinelatest.ts",
"./core/linq/observable/combinelatestproto.ts",
"./core/linq/observable/concat.ts",
"./core/linq/observable/concatall.ts",
"./core/linq/observable/concatmap.ts",
"./core/linq/observable/concatmapobserver.ts",
"./core/linq/observable/concatproto.ts",
"./core/linq/observable/count.ts",
"./core/linq/observable/create.ts",
"./core/linq/observable/debounce.ts",
"./core/linq/observable/defaultifempty.ts",
"./core/linq/observable/defer.ts",
"./core/linq/observable/delay.ts",
"./core/linq/observable/delaysubscription.ts",
"./core/linq/observable/dematerialize.ts",
"./core/linq/observable/distinct.ts",
"./core/linq/observable/distinctuntilchanged.ts",
"./core/linq/observable/dowhile.ts",
"./core/linq/observable/elementat.ts",
"./core/linq/observable/empty.ts",
"./core/linq/observable/every.ts",
"./core/linq/observable/expand.ts",
"./core/linq/observable/filter.ts",
"./core/linq/observable/finally.ts",
"./core/linq/observable/find.ts",
"./core/linq/observable/findindex.ts",
"./core/linq/observable/first.ts",
"./core/linq/observable/flatmap.ts",
"./core/linq/observable/flatmapfirst.ts",
"./core/linq/observable/flatmaplatest.ts",
"./core/linq/observable/flatmapwithmaxconcurrent.ts",
"./core/linq/observable/for.ts",
"./core/linq/observable/forkjoin.ts",
"./core/linq/observable/forkjoinproto.ts",
"./core/linq/observable/from.ts",
"./core/linq/observable/fromarray.ts",
"./core/linq/observable/fromcallback.ts",
"./core/linq/observable/fromevent.ts",
"./core/linq/observable/fromeventpattern.ts",
"./core/linq/observable/fromnodecallback.ts",
"./core/linq/observable/frompromise.ts",
"./core/linq/observable/generate.ts",
"./core/linq/observable/generatewithabsolutetime.ts",
"./core/linq/observable/generatewithrelativetime.ts",
"./core/linq/observable/groupby.ts",
"./core/linq/observable/groupbyuntil.ts",
"./core/linq/observable/groupjoin.ts",
"./core/linq/observable/if.ts",
"./core/linq/observable/ignoreelements.ts",
"./core/linq/observable/includes.ts",
"./core/linq/observable/indexof.ts",
"./core/linq/observable/interval.ts",
"./core/linq/observable/isempty.ts",
"./core/linq/observable/join.ts",
"./core/linq/observable/jortsort.ts",
"./core/linq/observable/jortsortuntil.ts",
"./core/linq/observable/just.ts",
"./core/linq/observable/last.ts",
"./core/linq/observable/let.ts",
"./core/linq/observable/manyselect.ts",
"./core/linq/observable/map.ts",
"./core/linq/observable/materialize.ts",
"./core/linq/observable/max.ts",
"./core/linq/observable/maxby.ts",
"./core/linq/observable/merge.ts",
"./core/linq/observable/mergeall.ts",
"./core/linq/observable/mergedelayerror.ts",
"./core/linq/observable/mergeproto.ts",
"./core/linq/observable/min.ts",
"./core/linq/observable/minby.ts",
"./core/linq/observable/multicast.ts",
"./core/linq/observable/never.ts",
"./core/linq/observable/observeon.ts",
"./core/linq/observable/of.ts",
"./core/linq/observable/ofarraychanges.ts",
"./core/linq/observable/ofobjectchanges.ts",
"./core/linq/observable/onerrorresumenext.ts",
"./core/linq/observable/onerrorresumenextproto.ts",
"./core/linq/observable/pairs.ts",
"./core/linq/observable/pairwise.ts",
"./core/linq/observable/partition.ts",
"./core/linq/observable/pipe.ts",
"./core/linq/observable/pluck.ts",
"./core/linq/observable/publish.ts",
"./core/linq/observable/publishlast.ts",
"./core/linq/observable/publishvalue.ts",
"./core/linq/observable/range.ts",
"./core/linq/observable/reduce.ts",
"./core/linq/observable/repeat.ts",
"./core/linq/observable/repeatproto.ts",
"./core/linq/observable/replay.ts",
"./core/linq/observable/retry.ts",
"./core/linq/observable/retrywhen.ts",
"./core/linq/observable/sample.ts",
"./core/linq/observable/scan.ts",
"./core/linq/observable/selectmanyobserver.ts",
"./core/linq/observable/sequenceequal.ts",
"./core/linq/observable/share.ts",
"./core/linq/observable/sharereplay.ts",
"./core/linq/observable/sharevalue.ts",
"./core/linq/observable/single.ts",
"./core/linq/observable/singleinstance.ts",
"./core/linq/observable/skip.ts",
"./core/linq/observable/skiplast.ts",
"./core/linq/observable/skiplastwithtime.ts",
"./core/linq/observable/skipuntil.ts",
"./core/linq/observable/skipuntilwithtime.ts",
"./core/linq/observable/skipwhile.ts",
"./core/linq/observable/skipwithtime.ts",
"./core/linq/observable/some.ts",
"./core/linq/observable/spawn.ts",
"./core/linq/observable/start.ts",
"./core/linq/observable/startasync.ts",
"./core/linq/observable/startwith.ts",
"./core/linq/observable/subscribeon.ts",
"./core/linq/observable/sum.ts",
"./core/linq/observable/switch.ts",
"./core/linq/observable/switchfirst.ts",
"./core/linq/observable/take.ts",
"./core/linq/observable/takelast.ts",
"./core/linq/observable/takelastbuffer.ts",
"./core/linq/observable/takelastbufferwithtime.ts",
"./core/linq/observable/takelastwithtime.ts",
"./core/linq/observable/takeuntil.ts",
"./core/linq/observable/takeuntilwithtime.ts",
"./core/linq/observable/takewhile.ts",
"./core/linq/observable/takewithtime.ts",
"./core/linq/observable/tap.ts",
"./core/linq/observable/thendo.ts",
"./core/linq/observable/throttle.ts",
"./core/linq/observable/throw.ts",
"./core/linq/observable/timeinterval.ts",
"./core/linq/observable/timeout.ts",
"./core/linq/observable/timer.ts",
"./core/linq/observable/timestamp.ts",
"./core/linq/observable/toarray.ts",
"./core/linq/observable/toasync.ts",
"./core/linq/observable/tomap.ts",
"./core/linq/observable/topromise.ts",
"./core/linq/observable/toset.ts",
"./core/linq/observable/transduce.ts",
"./core/linq/observable/using.ts",
"./core/linq/observable/when.ts",
"./core/linq/observable/while.ts",
"./core/linq/observable/window.ts",
"./core/linq/observable/windowwithcount.ts",
"./core/linq/observable/windowwithtime.ts",
"./core/linq/observable/windowwithtimeorcount.ts",
"./core/linq/observable/withlatestfrom.ts",
"./core/linq/observable/zip.ts",
"./core/linq/observable/zipiterable.ts",
"./core/linq/observable/zipproto.ts",
"./core/notification.ts",
"./core/observable.ts",
"./core/observer-extras.ts",
"./core/observer-lite.ts",
"./core/observer.ts",
"./core/scheduledobserver.ts",
"./core/subjects/anonymoussubject.ts",
"./core/subjects/asyncsubject.ts",
"./core/subjects/behaviorsubject.ts",
"./core/subjects/replaysubject.ts",
"./core/subjects/subject.ts",
"./core/testing/mockdisposable.ts",
"./core/testing/mockobserver.ts",
"./core/testing/reactivetest.ts",
"./core/testing/recorded.ts",
"./core/testing/subscription.ts",
"./core/testing/testscheduler.ts"
]
"core/abstractobserver.ts",
"core/anonymousobservable.ts",
"core/anonymousobserver.ts",
"core/backpressure/controlled.ts",
"core/backpressure/pausable.ts",
"core/backpressure/pausablebuffered.ts",
"core/backpressure/pauser.ts",
"core/backpressure/stopandwait.ts",
"core/backpressure/windowed.ts",
"core/checkedobserver.ts",
"core/concurrency/currentthreadscheduler.ts",
"core/concurrency/defaultscheduler.ts",
"core/concurrency/historicalscheduler.ts",
"core/concurrency/immediatescheduler.ts",
"core/concurrency/scheduleditem.ts",
"core/concurrency/scheduleperiodicrecursive.ts",
"core/concurrency/scheduler.periodic.ts",
"core/concurrency/scheduler.recursive.ts",
"core/concurrency/scheduler.ts",
"core/concurrency/scheduler.wrappers.ts",
"core/concurrency/virtualtimescheduler.ts",
"core/disposables/booleandisposable.ts",
"core/disposables/compositedisposable.ts",
"core/disposables/disposable.ts",
"core/disposables/refcountdisposable.ts",
"core/internal/bindcallback.ts",
"core/internal/errors.ts",
"core/internal/isequal.ts",
"core/internal/priorityqueue.ts",
"core/internal/util.ts",
"core/joins/pattern.ts",
"core/joins/plan.ts",
"core/linq/connectableobservable.ts",
"core/linq/groupedobservable.ts",
"core/linq/observable/amb.ts",
"core/linq/observable/ambproto.ts",
"core/linq/observable/and.ts",
"core/linq/observable/asobservable.ts",
"core/linq/observable/average.ts",
"core/linq/observable/buffer.ts",
"core/linq/observable/bufferwithcount.ts",
"core/linq/observable/bufferwithtime.ts",
"core/linq/observable/bufferwithtimeorcount.ts",
"core/linq/observable/case.ts",
"core/linq/observable/catch.ts",
"core/linq/observable/catchproto.ts",
"core/linq/observable/combinelatest.ts",
"core/linq/observable/combinelatestproto.ts",
"core/linq/observable/concat.ts",
"core/linq/observable/concatall.ts",
"core/linq/observable/concatmap.ts",
"core/linq/observable/concatmapobserver.ts",
"core/linq/observable/concatproto.ts",
"core/linq/observable/count.ts",
"core/linq/observable/create.ts",
"core/linq/observable/debounce.ts",
"core/linq/observable/defaultifempty.ts",
"core/linq/observable/defer.ts",
"core/linq/observable/delay.ts",
"core/linq/observable/delaysubscription.ts",
"core/linq/observable/dematerialize.ts",
"core/linq/observable/distinct.ts",
"core/linq/observable/distinctuntilchanged.ts",
"core/linq/observable/dowhile.ts",
"core/linq/observable/elementat.ts",
"core/linq/observable/empty.ts",
"core/linq/observable/every.ts",
"core/linq/observable/expand.ts",
"core/linq/observable/filter.ts",
"core/linq/observable/finally.ts",
"core/linq/observable/find.ts",
"core/linq/observable/findindex.ts",
"core/linq/observable/first.ts",
"core/linq/observable/flatmap.ts",
"core/linq/observable/flatmapfirst.ts",
"core/linq/observable/flatmaplatest.ts",
"core/linq/observable/flatmapwithmaxconcurrent.ts",
"core/linq/observable/for.ts",
"core/linq/observable/forkjoin.ts",
"core/linq/observable/forkjoinproto.ts",
"core/linq/observable/from.ts",
"core/linq/observable/fromarray.ts",
"core/linq/observable/fromcallback.ts",
"core/linq/observable/fromevent.ts",
"core/linq/observable/fromeventpattern.ts",
"core/linq/observable/fromnodecallback.ts",
"core/linq/observable/frompromise.ts",
"core/linq/observable/generate.ts",
"core/linq/observable/generatewithabsolutetime.ts",
"core/linq/observable/generatewithrelativetime.ts",
"core/linq/observable/groupby.ts",
"core/linq/observable/groupbyuntil.ts",
"core/linq/observable/groupjoin.ts",
"core/linq/observable/if.ts",
"core/linq/observable/ignoreelements.ts",
"core/linq/observable/includes.ts",
"core/linq/observable/indexof.ts",
"core/linq/observable/interval.ts",
"core/linq/observable/isempty.ts",
"core/linq/observable/join.ts",
"core/linq/observable/jortsort.ts",
"core/linq/observable/jortsortuntil.ts",
"core/linq/observable/just.ts",
"core/linq/observable/last.ts",
"core/linq/observable/let.ts",
"core/linq/observable/manyselect.ts",
"core/linq/observable/map.ts",
"core/linq/observable/materialize.ts",
"core/linq/observable/max.ts",
"core/linq/observable/maxby.ts",
"core/linq/observable/merge.ts",
"core/linq/observable/mergeall.ts",
"core/linq/observable/mergedelayerror.ts",
"core/linq/observable/mergeproto.ts",
"core/linq/observable/min.ts",
"core/linq/observable/minby.ts",
"core/linq/observable/multicast.ts",
"core/linq/observable/never.ts",
"core/linq/observable/observeon.ts",
"core/linq/observable/of.ts",
"core/linq/observable/ofarraychanges.ts",
"core/linq/observable/ofobjectchanges.ts",
"core/linq/observable/onerrorresumenext.ts",
"core/linq/observable/onerrorresumenextproto.ts",
"core/linq/observable/pairs.ts",
"core/linq/observable/pairwise.ts",
"core/linq/observable/partition.ts",
"core/linq/observable/pipe.ts",
"core/linq/observable/pluck.ts",
"core/linq/observable/publish.ts",
"core/linq/observable/publishlast.ts",
"core/linq/observable/publishvalue.ts",
"core/linq/observable/range.ts",
"core/linq/observable/reduce.ts",
"core/linq/observable/repeat.ts",
"core/linq/observable/repeatproto.ts",
"core/linq/observable/replay.ts",
"core/linq/observable/retry.ts",
"core/linq/observable/retrywhen.ts",
"core/linq/observable/sample.ts",
"core/linq/observable/scan.ts",
"core/linq/observable/selectmanyobserver.ts",
"core/linq/observable/sequenceequal.ts",
"core/linq/observable/share.ts",
"core/linq/observable/sharereplay.ts",
"core/linq/observable/sharevalue.ts",
"core/linq/observable/single.ts",
"core/linq/observable/singleinstance.ts",
"core/linq/observable/skip.ts",
"core/linq/observable/skiplast.ts",
"core/linq/observable/skiplastwithtime.ts",
"core/linq/observable/skipuntil.ts",
"core/linq/observable/skipuntilwithtime.ts",
"core/linq/observable/skipwhile.ts",
"core/linq/observable/skipwithtime.ts",
"core/linq/observable/some.ts",
"core/linq/observable/spawn.ts",
"core/linq/observable/start.ts",
"core/linq/observable/startasync.ts",
"core/linq/observable/startwith.ts",
"core/linq/observable/subscribeon.ts",
"core/linq/observable/sum.ts",
"core/linq/observable/switch.ts",
"core/linq/observable/switchfirst.ts",
"core/linq/observable/take.ts",
"core/linq/observable/takelast.ts",
"core/linq/observable/takelastbuffer.ts",
"core/linq/observable/takelastbufferwithtime.ts",
"core/linq/observable/takelastwithtime.ts",
"core/linq/observable/takeuntil.ts",
"core/linq/observable/takeuntilwithtime.ts",
"core/linq/observable/takewhile.ts",
"core/linq/observable/takewithtime.ts",
"core/linq/observable/tap.ts",
"core/linq/observable/thendo.ts",
"core/linq/observable/throttle.ts",
"core/linq/observable/throw.ts",
"core/linq/observable/timeinterval.ts",
"core/linq/observable/timeout.ts",
"core/linq/observable/timer.ts",
"core/linq/observable/timestamp.ts",
"core/linq/observable/toarray.ts",
"core/linq/observable/toasync.ts",
"core/linq/observable/tomap.ts",
"core/linq/observable/topromise.ts",
"core/linq/observable/toset.ts",
"core/linq/observable/transduce.ts",
"core/linq/observable/using.ts",
"core/linq/observable/when.ts",
"core/linq/observable/while.ts",
"core/linq/observable/window.ts",
"core/linq/observable/windowwithcount.ts",
"core/linq/observable/windowwithtime.ts",
"core/linq/observable/windowwithtimeorcount.ts",
"core/linq/observable/withlatestfrom.ts",
"core/linq/observable/zip.ts",
"core/linq/observable/zipiterable.ts",
"core/linq/observable/zipproto.ts",
"core/notification.ts",
"core/observable.ts",
"core/observer-extras.ts",
"core/observer-lite.ts",
"core/observer.ts",
"core/scheduledobserver.ts",
"core/subjects/anonymoussubject.ts",
"core/subjects/asyncsubject.ts",
"core/subjects/behaviorsubject.ts",
"core/subjects/replaysubject.ts",
"core/subjects/subject.ts",
"core/testing/mockdisposable.ts",
"core/testing/mockobserver.ts",
"core/testing/reactivetest.ts",
"core/testing/recorded.ts",
"core/testing/subscription.ts",
"core/testing/testscheduler.ts"
],
"exclude": []
}
src/core/abstractobserver.js
src/core/anonymousobservable.js
src/core/anonymousobserver.js
src/core/autodetachobserver.js
src/core/backpressure/controlled.js
src/core/backpressure/pausable.js
src/core/backpressure/pausablebuffered.js
src/core/backpressure/pauser.js
src/core/backpressure/stopandwait.js
src/core/backpressure/windowed.js
src/core/checkedobserver.js
src/core/concurrency/catchscheduler.js
src/core/concurrency/currentthreadscheduler.js
src/core/concurrency/defaultscheduler.js
src/core/concurrency/historicalscheduler.js
src/core/concurrency/immediatescheduler.js
src/core/concurrency/scheduleditem.js
src/core/concurrency/scheduleperiodicrecursive.js
src/core/concurrency/scheduler.js
src/core/concurrency/scheduler.periodic.js
src/core/concurrency/scheduler.recursive.js
src/core/concurrency/scheduler.wrappers.js
src/core/concurrency/virtualtimescheduler.js
src/core/disposables/binarydisposable.js
src/core/disposables/booleandisposable.js
src/core/disposables/compositedisposable.js
src/core/disposables/disposable.js
src/core/disposables/refcountdisposable.js
src/core/disposables/scheduleddisposable.js
src/core/enumerable.js
src/core/expressions/app.css
src/core/expressions/app.js
src/core/expressions/app.js.map
src/core/expressions/app.ts
src/core/expressions/compiler.js
src/core/expressions/compiler.js.map
src/core/expressions/compiler.ts
src/core/expressions/ExpressionTrees.csproj
src/core/expressions/ExpressionTrees.csproj.user
src/core/expressions/ExpressionTrees.sln
src/core/expressions/index.html
src/core/expressions/web.config
src/core/expressions/web.Debug.config
src/core/expressions/web.Release.config
src/core/headers/aggregatesheader.js
src/core/headers/asyncheader.js
src/core/headers/asyncintro.js
src/core/headers/backpressureheader.js
src/core/headers/basicheader-compat.js
src/core/headers/basicheader.js
src/core/headers/bindingheader.js
src/core/headers/coincidenceheader.js
src/core/headers/core-bindingheader.js
src/core/headers/core-intro.js
src/core/headers/core-testheader.js
src/core/headers/coreheader.js
src/core/headers/enumeratorheader.js
src/core/headers/experimentalheader.js
src/core/headers/exports.js
src/core/headers/intro.js
src/core/headers/joinpatternsheader.js
src/core/headers/license.js
src/core/headers/liteextrasheader.js
src/core/headers/liteheader-compat.js
src/core/headers/liteheader.js
src/core/headers/liteintro-compat.js
src/core/headers/liteintro.js
src/core/headers/litetestintro-compat.js
src/core/headers/litetestintro.js
src/core/headers/outro.js
src/core/headers/sortingheader.js
src/core/headers/subintro.js
src/core/headers/suboutro.js
src/core/headers/testheader.js
src/core/headers/testintro.js
src/core/headers/timeheader.js
src/core/headers/virtualtimeheader.js
src/core/internal/bindcallback.js
src/core/internal/dontenums.js
src/core/internal/errors.js
src/core/internal/isequal.js
src/core/internal/map.js
src/core/internal/polyfills.js
src/core/internal/priorityqueue.js
src/core/internal/trycatch.js
src/core/internal/util.js
src/core/joins/activeplan.js
src/core/joins/joinobserver.js
src/core/joins/pattern.js
src/core/joins/plan.js
src/core/linq/connectableobservable.js
src/core/linq/enumerable/while.js
src/core/linq/groupedobservable.js
src/core/linq/observable/_extremaby.js
src/core/linq/observable/_findvalue.js
src/core/linq/observable/_firstonly.js
src/core/linq/observable/_observabletimer.js
src/core/linq/observable/_observabletimerdateandperiod.js
src/core/linq/observable/_observabletimertimespanandperiod.js
src/core/linq/observable/amb.js
src/core/linq/observable/ambproto.js
src/core/linq/observable/and.js
src/core/linq/observable/asobservable.js
src/core/linq/observable/average.js
src/core/linq/observable/buffer.js
src/core/linq/observable/bufferwithcount.js
src/core/linq/observable/bufferwithtime.js
src/core/linq/observable/bufferwithtimeorcount.js
src/core/linq/observable/case.js
src/core/linq/observable/catch.js
src/core/linq/observable/catchproto.js
src/core/linq/observable/combinedsynchronized.js
src/core/linq/observable/combinelatest.js
src/core/linq/observable/combinelatestproto.js
src/core/linq/observable/concat.js
src/core/linq/observable/concatall.js
src/core/linq/observable/concatmap.js
src/core/linq/observable/concatmapobserver.js
src/core/linq/observable/concatproto.js
src/core/linq/observable/count.js
src/core/linq/observable/create.js
src/core/linq/observable/debounce.js
src/core/linq/observable/defaultifempty.js
src/core/linq/observable/defer.js
src/core/linq/observable/delay.js
src/core/linq/observable/delaysubscription.js
src/core/linq/observable/dematerialize.js
src/core/linq/observable/distinct.js
src/core/linq/observable/distinctuntilchanged.js
src/core/linq/observable/do.js
src/core/linq/observable/dowhile.js
src/core/linq/observable/elementat.js
src/core/linq/observable/empty.js
src/core/linq/observable/every.js
src/core/linq/observable/expand.js
src/core/linq/observable/finally.js
src/core/linq/observable/find.js
src/core/linq/observable/findindex.js
src/core/linq/observable/first.js
src/core/linq/observable/flatmapfirst.js
src/core/linq/observable/flatmaplatest.js
src/core/linq/observable/flatmapwithmaxconcurrent.js
src/core/linq/observable/for.js
src/core/linq/observable/forkjoin.js
src/core/linq/observable/forkjoinproto.js
src/core/linq/observable/from.js
src/core/linq/observable/fromarray.js
src/core/linq/observable/fromcallback.js
src/core/linq/observable/fromevent.js
src/core/linq/observable/fromeventpattern.js
src/core/linq/observable/fromnodecallback.js
src/core/linq/observable/frompromise.js
src/core/linq/observable/generate.js
src/core/linq/observable/generatewithabsolutetime.js
src/core/linq/observable/generatewithrelativetime.js
src/core/linq/observable/groupby.js
src/core/linq/observable/groupbyuntil.js
src/core/linq/observable/groupjoin.js
src/core/linq/observable/if.js
src/core/linq/observable/ignoreelements.js
src/core/linq/observable/includes.js
src/core/linq/observable/indexof.js
src/core/linq/observable/interval.js
src/core/linq/observable/isempty.js
src/core/linq/observable/join.js
src/core/linq/observable/jortsort.js
src/core/linq/observable/jortsortuntil.js
src/core/linq/observable/last.js
src/core/linq/observable/lastindexof.js
src/core/linq/observable/let.js
src/core/linq/observable/manyselect.js
src/core/linq/observable/materialize.js
src/core/linq/observable/max.js
src/core/linq/observable/maxby.js
src/core/linq/observable/merge.js
src/core/linq/observable/mergeall.js
src/core/linq/observable/mergeconcat.js
src/core/linq/observable/mergedelayerror.js
src/core/linq/observable/min.js
src/core/linq/observable/minby.js
src/core/linq/observable/multicast.js
src/core/linq/observable/never.js
src/core/linq/observable/observeon.js
src/core/linq/observable/of.js
src/core/linq/observable/ofarraychanges.js
src/core/linq/observable/ofobjectchanges.js
src/core/linq/observable/onerrorresumenext.js
src/core/linq/observable/onerrorresumenextproto.js
src/core/linq/observable/pairs.js
src/core/linq/observable/pairwise.js
src/core/linq/observable/partition.js
src/core/linq/observable/pipe.js
src/core/linq/observable/pluck.js
src/core/linq/observable/publish.js
src/core/linq/observable/publishlast.js
src/core/linq/observable/publishvalue.js
src/core/linq/observable/range.js
src/core/linq/observable/reduce.js
src/core/linq/observable/repeat.js
src/core/linq/observable/repeatproto.js
src/core/linq/observable/replay.js
src/core/linq/observable/retry.js
src/core/linq/observable/retrywhen.js
src/core/linq/observable/return.js
src/core/linq/observable/sample.js
src/core/linq/observable/scan.js
src/core/linq/observable/select.js
src/core/linq/observable/selectmany.js
src/core/linq/observable/selectmanyobserver.js
src/core/linq/observable/sequenceequal.js
src/core/linq/observable/share.js
src/core/linq/observable/sharereplay.js
src/core/linq/observable/sharevalue.js
src/core/linq/observable/single.js
src/core/linq/observable/singleinstance.js
src/core/linq/observable/skip.js
src/core/linq/observable/skiplast.js
src/core/linq/observable/skiplastwithtime.js
src/core/linq/observable/skipuntil.js
src/core/linq/observable/skipuntilwithtime.js
src/core/linq/observable/skipwhile.js
src/core/linq/observable/skipwithtime.js
src/core/linq/observable/slice.js
src/core/linq/observable/some.js
src/core/linq/observable/spawn.js
src/core/linq/observable/start.js
src/core/linq/observable/startasync.js
src/core/linq/observable/startwith.js
src/core/linq/observable/subscribeon.js
src/core/linq/observable/sum.js
src/core/linq/observable/switch.js
src/core/linq/observable/switchfirst.js
src/core/linq/observable/take.js
src/core/linq/observable/takelast.js
src/core/linq/observable/takelastbuffer.js
src/core/linq/observable/takelastbufferwithtime.js
src/core/linq/observable/takelastwithtime.js
src/core/linq/observable/takeuntil.js
src/core/linq/observable/takeuntilwithtime.js
src/core/linq/observable/takewhile.js
src/core/linq/observable/takewithtime.js
src/core/linq/observable/thendo.js
src/core/linq/observable/throttle.js
src/core/linq/observable/throw.js
src/core/linq/observable/timeinterval.js
src/core/linq/observable/timeout.js
src/core/linq/observable/timer.js
src/core/linq/observable/timestamp.js
src/core/linq/observable/toarray.js
src/core/linq/observable/toasync.js
src/core/linq/observable/tomap.js
src/core/linq/observable/topromise.js
src/core/linq/observable/toset.js
src/core/linq/observable/transduce.js
src/core/linq/observable/using.js
src/core/linq/observable/when.js
src/core/linq/observable/where.js
src/core/linq/observable/while.js
src/core/linq/observable/window.js
src/core/linq/observable/windowwithcount.js
src/core/linq/observable/windowwithtime.js
src/core/linq/observable/windowwithtimeorcount.js
src/core/linq/observable/withlatestfrom.js
src/core/linq/observable/zip.js
src/core/linq/observable/zipiterable.js
src/core/linq/observable/zipproto.js
src/core/longstacktraces/longstackbegin.js
src/core/longstacktraces/longstackend.js
src/core/longstacktraces/longstacktraces.js
src/core/notification.js
src/core/observable.js
src/core/observeonobserver.js
src/core/observer-extras.js
src/core/observer-lite.js
src/core/observer.js
src/core/perf/observablebase.js
src/core/perf/operators/combinelatest.js
src/core/perf/operators/concat.js
src/core/perf/operators/concatmap.js
src/core/perf/operators/distinctuntilchanged.js
src/core/perf/operators/empty.js
src/core/perf/operators/filter.js
src/core/perf/operators/finally.js
src/core/perf/operators/flatmap.js
src/core/perf/operators/flatmapbase.js
src/core/perf/operators/flatmapfirst.js
src/core/perf/operators/flatmaplatest.js
src/core/perf/operators/flatmapwithmaxconcurrent.js
src/core/perf/operators/from.js
src/core/perf/operators/fromarray.js
src/core/perf/operators/fromarrayobservable.js
src/core/perf/operators/fromcallback.js
src/core/perf/operators/fromnodecallback.js
src/core/perf/operators/frompromise.js
src/core/perf/operators/ignoreelements.js
src/core/perf/operators/just.js
src/core/perf/operators/map.js
src/core/perf/operators/mergeall.js
src/core/perf/operators/mergeconcat.js
src/core/perf/operators/never.js
src/core/perf/operators/of.js
src/core/perf/operators/pairs.js
src/core/perf/operators/range.js
src/core/perf/operators/reduce.js
src/core/perf/operators/repeat.js
src/core/perf/operators/scan.js
src/core/perf/operators/skip.js
src/core/perf/operators/skipuntil.js
src/core/perf/operators/switch.js
src/core/perf/operators/take.js
src/core/perf/operators/takeuntil.js
src/core/perf/operators/tap.js
src/core/perf/operators/throw.js
src/core/perf/operators/toarray.js
src/core/perf/operators/withlatestfrom.js
src/core/perf/operators/zip.js
src/core/scheduledobserver.js
src/core/subjects/anonymoussubject.js
src/core/subjects/asyncsubject.js
src/core/subjects/behaviorsubject.js
src/core/subjects/innersubscription.js
src/core/subjects/replaysubject.js
src/core/subjects/subject.js
src/core/testing/coldobservable.js
src/core/testing/hotobservable.js
src/core/testing/mockdisposable.js
src/core/testing/mockobserver.js
src/core/testing/mockpromise.js
src/core/testing/reactivetest.js
src/core/testing/recorded.js
src/core/testing/subscription.js
src/core/testing/testscheduler.js
src/modular/compat/observable.js
src/modular/compat/package.json
src/modular/modern/helpers/isfunction.js
src/modular/modern/internal/abstractobserver.js
src/modular/modern/internal/anonymousobservable.js
src/modular/modern/internal/autodetachobserver.js
src/modular/modern/observable.js
src/modular/modern/observable/anonymousobservable.js
src/modular/modern/observable/observablebase.js
src/modular/modern/observer.js
src/modular/modern/observer/asobserver.js
src/modular/modern/observer/checked.js
src/modular/modern/observer/fromnotifier.js
src/modular/modern/observer/makesafe.js
src/modular/modern/observer/notifyon.js
src/modular/modern/observer/tonotifier.js
src/modular/modern/package.json
src/modular/modern/scheduler.js
ts/core/linq/observable/mergeproto.ts
ts/core/linq/observable/zipproto.ts
dist/rx.all.compat.js

Sorry, the diff of this file is too big to display

dist/rx.all.compat.map

Sorry, the diff of this file is not supported yet

dist/rx.all.compat.min.js

Sorry, the diff of this file is too big to display

dist/rx.all.js

Sorry, the diff of this file is too big to display

dist/rx.all.map

Sorry, the diff of this file is not supported yet

dist/rx.all.min.js

Sorry, the diff of this file is too big to display

dist/rx.async.compat.map

Sorry, the diff of this file is not supported yet

dist/rx.async.map

Sorry, the diff of this file is not supported yet

dist/rx.backpressure.map

Sorry, the diff of this file is not supported yet

dist/rx.binding.map

Sorry, the diff of this file is not supported yet

dist/rx.compat.js

Sorry, the diff of this file is too big to display

dist/rx.compat.map

Sorry, the diff of this file is not supported yet

dist/rx.compat.min.js

Sorry, the diff of this file is too big to display

dist/rx.core.binding.map

Sorry, the diff of this file is not supported yet

dist/rx.core.map

Sorry, the diff of this file is not supported yet

dist/rx.core.testing.map

Sorry, the diff of this file is not supported yet

dist/rx.experimental.map

Sorry, the diff of this file is not supported yet

dist/rx.js

Sorry, the diff of this file is too big to display

dist/rx.lite.compat.js

Sorry, the diff of this file is too big to display

dist/rx.lite.compat.map

Sorry, the diff of this file is not supported yet

dist/rx.lite.compat.min.js

Sorry, the diff of this file is too big to display

dist/rx.lite.extras.compat.map

Sorry, the diff of this file is not supported yet

dist/rx.lite.extras.map

Sorry, the diff of this file is not supported yet

dist/rx.lite.js

Sorry, the diff of this file is too big to display

dist/rx.lite.map

Sorry, the diff of this file is not supported yet

dist/rx.lite.min.js

Sorry, the diff of this file is too big to display

dist/rx.map

Sorry, the diff of this file is not supported yet

dist/rx.min.js

Sorry, the diff of this file is too big to display

ts/rx.all.d.ts

Sorry, the diff of this file is too big to display

ts/rx.all.es6.d.ts

Sorry, the diff of this file is too big to display

ts/rx.d.ts

Sorry, the diff of this file is too big to display

ts/rx.es6.d.ts

Sorry, the diff of this file is too big to display

ts/rx.lite.d.ts

Sorry, the diff of this file is too big to display

ts/rx.lite.es6.d.ts

Sorry, the diff of this file is too big to display

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc