Disable only AFTER all internal data is readed
This commit is contained in:
@@ -79,10 +79,6 @@ export class Subscribe {
|
|||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
subscribe() {
|
subscribe() {
|
||||||
if (this.disabled) {
|
|
||||||
throw new Exception(this.disabled, false);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (this.pending.length > 0) {
|
if (this.pending.length > 0) {
|
||||||
let p = this.pending.shift();
|
let p = this.pending.shift();
|
||||||
|
|
||||||
@@ -98,6 +94,10 @@ export class Subscribe {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (this.disabled) {
|
||||||
|
throw new Exception(this.disabled, false);
|
||||||
|
}
|
||||||
|
|
||||||
let self = this;
|
let self = this;
|
||||||
|
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
|
|||||||
Reference in New Issue
Block a user