Socket
Socket
Sign inDemoInstall

multistream

Package Overview
Dependencies
Maintainers
2
Versions
26
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

multistream - npm Package Compare versions

Comparing version 1.6.0 to 1.6.1

2

index.js

@@ -60,3 +60,3 @@ module.exports = MultiStream

var self = this
var stream = (typeof self._queue === 'function' ? self._queue() : self._queue.shift())
var stream = (typeof self._queue === 'function' ? toStreams2(self._queue()) : self._queue.shift())

@@ -63,0 +63,0 @@ if (typeof stream === 'function') stream = toStreams2(stream())

{
"name": "multistream",
"description": "A stream that emits multiple other streams one after another (streams2)",
"version": "1.6.0",
"version": "1.6.1",
"author": "Feross Aboukhadijeh <feross@feross.org> (http://feross.org/)",

@@ -6,0 +6,0 @@ "bugs": {

@@ -85,1 +85,26 @@ var concat = require('concat-stream')

})
test('lazy stream via generator (classic)', function (t) {
var count = 0
var streams = function () {
if (count > 2) {
return null
}
count++
var s = through()
process.nextTick(function () {
s.write(count.toString())
s.end()
})
return s
}
new MultiStream(streams)
.on('error', function (err) {
t.fail(err)
})
.pipe(concat(function (data) {
t.equal(data.toString(), '123')
t.end()
}))
})
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc