Skip to content

Commit f6c0157

Browse files
author
github1337
committed
Streaming blocked everything. Implemented workaround with setImmediate.
1 parent 88c166c commit f6c0157

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

lib/adapter.js

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -935,7 +935,9 @@ module.exports = (function() {
935935
dbStream.on('result', function(row) {
936936
connection.pause();
937937
stream.write(row, function() {
938-
connection.resume();
938+
setImmediate(function() {
939+
connection.resume();
940+
});
939941
});
940942
});
941943

0 commit comments

Comments
 (0)