From 56a1deb9d5ea7e3fb2beedbbc218ebf1d1fc719b Mon Sep 17 00:00:00 2001 From: syuilo Date: Fri, 16 Mar 2018 06:05:39 +0900 Subject: :v: --- src/web/app/common/scripts/streaming/stream.ts | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'src/web/app/common/scripts') diff --git a/src/web/app/common/scripts/streaming/stream.ts b/src/web/app/common/scripts/streaming/stream.ts index 189af0ab30..cb4041fd89 100644 --- a/src/web/app/common/scripts/streaming/stream.ts +++ b/src/web/app/common/scripts/streaming/stream.ts @@ -22,6 +22,7 @@ export default class Connection extends EventEmitter { data: string }> = []; public id: string; + public isSuspended = false; private os: MiOS; constructor(os: MiOS, endpoint, params?) { @@ -91,6 +92,8 @@ export default class Connection extends EventEmitter { * Callback of when received a message from connection */ private onMessage(message) { + if (this.isSuspended) return; + if (this.os.debug) { this.in++; this.inout.push({ type: 'in', at: new Date(), data: message.data }); @@ -108,6 +111,8 @@ export default class Connection extends EventEmitter { * Send a message to connection */ public send(data) { + if (this.isSuspended) return; + // まだ接続が確立されていなかったらバッファリングして次に接続した時に送信する if (this.state != 'connected') { this.buffer.push(data); -- cgit v1.2.3-freya