diff --git a/src/web/app/common/scripts/streaming/stream.ts b/src/web/app/common/scripts/streaming/stream.ts index 189af0ab3..cb4041fd8 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); diff --git a/src/web/app/desktop/views/components/taskmanager.vue b/src/web/app/desktop/views/components/taskmanager.vue index c0a8b2e9a..a00fabb04 100644 --- a/src/web/app/desktop/views/components/taskmanager.vue +++ b/src/web/app/desktop/views/components/taskmanager.vue @@ -94,6 +94,13 @@ +
+ Send + Suspend + Resume + Disconnect +
+ { + c.send(JSON.parse(json)); + }); } } });