object-stream-tools
Advanced tools
Comparing version 1.2.1 to 1.2.2
11
index.js
@@ -10,3 +10,3 @@ 'use strict' | ||
objectMode: true, | ||
transform: (obj, enc, cb) => transform(obj, cb), | ||
transform: function(obj, enc, cb) { transform.call(this, obj, cb) }, | ||
flush | ||
@@ -17,3 +17,3 @@ }) | ||
function thruParallel(maxConcurrency, transform, flush) { | ||
return through2Concurrent.obj({maxConcurrency}, | ||
return through2Concurrent.obj({ maxConcurrency }, | ||
(obj, enc, cb) => transform(obj, cb), flush | ||
@@ -24,3 +24,3 @@ ) | ||
function arrayToStream(data) { | ||
const newStream = new stream.Readable({objectMode: true}) | ||
const newStream = new stream.Readable({ objectMode: true }) | ||
data.forEach(item => newStream.push(item)) | ||
@@ -42,5 +42,4 @@ newStream.push(null) | ||
function newReadable() { | ||
const rs = new stream.Readable({objectMode: true}) | ||
rs._read = () => { | ||
} | ||
const rs = new stream.Readable({ objectMode: true }) | ||
rs._read = () => {} | ||
return rs | ||
@@ -47,0 +46,0 @@ } |
{ | ||
"name": "object-stream-tools", | ||
"version": "1.2.1", | ||
"version": "1.2.2", | ||
"description": "Useful tools for manipulating object streams. Will be especially helpful to developers used to map - filter - reduce approach of nodejs arrays.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
10970
185