Stream: Do not write before the connection is open

qasim9872 · Jun 4, 2020 · 5b7292a · 5b7292a
1 parent 1f28d76
commit 5b7292a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/StreamingClient.ts b/src/StreamingClient.ts
@@ -31,6 +31,7 @@ export class StreamingClient extends Writable {
         this.ws.on("message", this._onmessage.bind(this))
         this.ws.on("error", this._onerror.bind(this))
         this.ws.on("close", this._onclose.bind(this))
+        this.cork()
     }
 
     /**
@@ -39,6 +40,7 @@ export class StreamingClient extends Writable {
     private _onopen() {
         debugLog(`opened connection to aws transcribe`)
         this.emit(StreamingClient.EVENTS.OPEN)
+        this.uncork()
     }
 
     /**