Skip to content
This repository was archived by the owner on Apr 20, 2018. It is now read-only.

Commit 2de2a80

Browse files
Fixing isStopped on innerSubscription
1 parent 8814268 commit 2de2a80

19 files changed

Lines changed: 20 additions & 13 deletions

dist/rx.all.compat.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3376,6 +3376,7 @@
33763376
};
33773377
InnerObserver.prototype.onCompleted = function () {
33783378
if(!this.isStopped) {
3379+
this.isStopped = true;
33793380
var parent = this.parent;
33803381
parent.g.remove(this.sad);
33813382
if (parent.q.length > 0) {

dist/rx.all.compat.map

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.all.compat.min.js

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.all.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3231,6 +3231,7 @@
32313231
};
32323232
InnerObserver.prototype.onCompleted = function () {
32333233
if(!this.isStopped) {
3234+
this.isStopped = true;
32343235
var parent = this.parent;
32353236
parent.g.remove(this.sad);
32363237
if (parent.q.length > 0) {

dist/rx.all.map

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.all.min.js

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.compat.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3376,6 +3376,7 @@
33763376
};
33773377
InnerObserver.prototype.onCompleted = function () {
33783378
if(!this.isStopped) {
3379+
this.isStopped = true;
33793380
var parent = this.parent;
33803381
parent.g.remove(this.sad);
33813382
if (parent.q.length > 0) {

dist/rx.compat.map

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.compat.min.js

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3185,6 +3185,7 @@
31853185
};
31863186
InnerObserver.prototype.onCompleted = function () {
31873187
if(!this.isStopped) {
3188+
this.isStopped = true;
31883189
var parent = this.parent;
31893190
parent.g.remove(this.sad);
31903191
if (parent.q.length > 0) {

0 commit comments

Comments
 (0)