diff options
Diffstat (limited to 'deps/npm/node_modules/sorted-union-stream/node_modules/stream-iterate/index.js')
-rw-r--r-- | deps/npm/node_modules/sorted-union-stream/node_modules/stream-iterate/index.js | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/deps/npm/node_modules/sorted-union-stream/node_modules/stream-iterate/index.js b/deps/npm/node_modules/sorted-union-stream/node_modules/stream-iterate/index.js index 2dac155cbf..c60d6ab550 100644 --- a/deps/npm/node_modules/sorted-union-stream/node_modules/stream-iterate/index.js +++ b/deps/npm/node_modules/sorted-union-stream/node_modules/stream-iterate/index.js @@ -1,4 +1,5 @@ -var Readable = require('stream').Readable +var Readable = require('readable-stream').Readable +var shift = require('stream-shift') var stream2 = function (stream) { if (stream._readableState) return stream @@ -34,7 +35,7 @@ module.exports = function (stream) { var update = function () { if (!fn) return - data = stream.read() + data = shift(stream) if (data === null && !ended) return onresult() } |