diff --git a/ui/stream/subscribe.js b/ui/stream/subscribe.js index 00191c0..b09fe1f 100644 --- a/ui/stream/subscribe.js +++ b/ui/stream/subscribe.js @@ -79,10 +79,6 @@ export class Subscribe { * */ subscribe() { - if (this.disabled) { - throw new Exception(this.disabled, false); - } - if (this.pending.length > 0) { let p = this.pending.shift(); @@ -98,6 +94,10 @@ export class Subscribe { } } + if (this.disabled) { + throw new Exception(this.disabled, false); + } + let self = this; return new Promise((resolve, reject) => {