Don't pass concurrency as highWaterMark to Readable

4 years ago · 51e3da5fd7
1 changed files with 1 additions and 2 deletions
--- a/lib/query-stream.js
+++ b/lib/query-stream.js
@ -14,8 +14,7 @@ class QueryStream extends Readable {
    if (!opts.concurrency) opts.concurrency = opts.highWaterMark || node.concurrency

    super({
-      objectMode: true,
-      highWaterMark: opts.concurrency
+      objectMode: true
    })

    const cmd = node._commands.get(command)