pull-stream - npm Package Compare versions

Comparing version 2.3.0 to 2.4.0

docs/sources.md

@@ -15,7 +15,10 @@ # Sources
 
-## readArray (array)
+## values (array | object)
 
-create a SourceStream that from an array and then stops.
+create a SourceStream that reads the values from an array or object and then stops.
 
+## keys (array | object)
 
+stream the key names from an object (or array)
+
 ## count (max)
@@ -22,0 +25,0 @@

docs/throughs.md

@@ -60,2 +60,9 @@ # Throughs
 
+## group (len)
+
+chunk incoming data into arrays of max length `len`,
+(the last item may be shorter than len)
+
+Useful for items you can handle in batches.
+
 ## highWaterMark (n)
@@ -62,0 +69,0 @@

package.json

 {
   "name": "pull-stream",
   "description": "minimal pull stream",
-  "version": "2.3.0",
+  "version": "2.4.0",
   "homepage": "https://github.com/dominictarr/pull-stream",
@@ -6,0 +6,0 @@ "repository": {

sources.js

@@ -22,3 +22,4 @@
 
-var count = function (max) {
+var count = exports.count = 
+function (max) {
   var i = 0; max = max || Infinity
@@ -25,0 +26,0 @@ return function (end, cb) {

throughs.js

@@ -96,2 +96,31 @@ function prop (map) {
 
+var group = exports.group =
+function (read, size) {
+  var ended; size = size || 5
+  var queue = []
+
+  return function (end, cb) {
+    //this means that the upstream is sending an error.
+    if(end) return read(ended = end, cb)
+    //this means that we read an end before.
+    if(ended) return cb(ended)
+
+    read(null, function next(end, data) {
+      if(ended = ended || end) {
+        if(!queue.length)
+          return cb(ended)
+
+        var _queue = queue; queue = []
+        return cb(null, _queue)
+      }
+      queue.push(data)
+      if(queue.length < size)
+        return read(null, next)
+
+      var _queue = queue; queue = []
+      cb(null, _queue)
+    })
+  }
+}
+
 var nextTick = process.nextTick
@@ -98,0 +127,0 @@

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

27247

increased by5.67%

Number of package files

19

increased by5.56%

Lines of code

642

increased by7.9%

No dependency changes