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

Commit c314375

Browse files
Updating build
1 parent 4dd20e1 commit c314375

27 files changed

+47
-20
lines changed

dist/rx.all.compat.js

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8714,6 +8714,9 @@ Observable.fromNodeCallback = function (fn, ctx, selector) {
87148714

87158715
ConnectableObservable.prototype.connect = function () {
87168716
if (!this._connection) {
8717+
if (this._subject.isStopped) {
8718+
return disposableEmpty;
8719+
}
87178720
var subscription = this._source.subscribe(this._subject);
87188721
this._connection = new ConnectDisposable(this, subscription);
87198722
}

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: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.all.js

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8452,6 +8452,9 @@ Observable.fromNodeCallback = function (fn, ctx, selector) {
84528452

84538453
ConnectableObservable.prototype.connect = function () {
84548454
if (!this._connection) {
8455+
if (this._subject.isStopped) {
8456+
return disposableEmpty;
8457+
}
84558458
var subscription = this._source.subscribe(this._subject);
84568459
this._connection = new ConnectDisposable(this, subscription);
84578460
}

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: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

dist/rx.binding.js

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -516,6 +516,9 @@
516516

517517
ConnectableObservable.prototype.connect = function () {
518518
if (!this._connection) {
519+
if (this._subject.isStopped) {
520+
return disposableEmpty;
521+
}
519522
var subscription = this._source.subscribe(this._subject);
520523
this._connection = new ConnectDisposable(this, subscription);
521524
}

dist/rx.binding.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.binding.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.core.binding.js

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -839,6 +839,9 @@
839839

840840
ConnectableObservable.prototype.connect = function () {
841841
if (!this._connection) {
842+
if (this._subject.isStopped) {
843+
return disposableEmpty;
844+
}
842845
var subscription = this._source.subscribe(this._subject);
843846
this._connection = new ConnectDisposable(this, subscription);
844847
}

0 commit comments

Comments
 (0)