Skip to content

Commit cc675a8

Browse files
committed
copying recognizeStream#afterSend fixes from node SDK
1 parent 4560365 commit cc675a8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

speech-to-text/recognize-stream.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -381,8 +381,8 @@ RecognizeStream.prototype._write = function(chunk, encoding, callback) {
381381
// flow control - don't ask for more data until we've finished what we have
382382
// todo: see if this can be improved
383383
RecognizeStream.prototype.afterSend = function afterSend(next) {
384-
if (this.socket.bufferedAmount <= this._writableState.highWaterMark || 0) {
385-
next(); // eslint-disable-line callback-return
384+
if (this.socket.bufferedAmount <= (this._writableState.highWaterMark || 0)) {
385+
process.nextTick(next);
386386
} else {
387387
setTimeout(this.afterSend.bind(this, next), 10);
388388
}

0 commit comments

Comments
 (0)