summaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/sorted-union-stream/node_modules/stream-iterate/index.js
diff options
context:
space:
mode:
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.js5
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()
}