Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

event-stream

Package Overview
Dependencies
Maintainers
1
Versions
84
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

event-stream - npm Package Compare versions

Comparing version 3.2.2 to 3.3.0

3

index.js

@@ -34,2 +34,5 @@ //filter will reemit the data if cb(err,pass) pass is truthy

var toMerge = [].slice.call(arguments)
if (toMerge.length === 1 && (toMerge[0] instanceof Array)) {
toMerge = toMerge[0] //handle array as arguments object
}
var stream = new Stream()

@@ -36,0 +39,0 @@ stream.setMaxListeners(0) // allow adding more than 11 streams

2

package.json
{
"name": "event-stream",
"version": "3.2.2",
"version": "3.3.0",
"description": "construct pipes of streams of events",

@@ -5,0 +5,0 @@ "homepage": "http://github.com/dominictarr/event-stream",

@@ -11,2 +11,3 @@ var es = require('../')

var r2 = es.readArray(odd)
var endCount = 0

@@ -16,8 +17,15 @@ var writer = es.writeArray(function (err, array){

it(array.sort()).deepEqual(even.concat(odd).sort())
t.done()
if (++endCount === 2) t.done()
})
var writer2 = es.writeArray(function (err, array){
if(err) throw err //unpossible
it(array.sort()).deepEqual(even.concat(odd).sort())
if (++endCount === 2) t.done()
})
es.merge(r1, r2).pipe(writer)
es.merge([r1, r2]).pipe(writer2)
}
require('./helper')(module)

Sorry, the diff of this file is not supported yet

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