pull-stream - npm Package Compare versions

Comparing version 2.2.0 to 2.3.0

docs/throughs.md

@@ -45,2 +45,13 @@ # Throughs
 
+## unique (prop)
+
+Filter items that have a repeated value for `prop()`,
+by default, `prop = function (it) {return it }`, if prop is a string,
+it will filter nodes which have repeated values for that property.
+
+## nonUnique (prop)
+
+filter unique items -- get the duplicates.
+The inverse of `unique`
+
 ## take (test)
@@ -47,0 +58,0 @@

package.json

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

throughs.js

@@ -0,1 +1,13 @@
+function prop (map) {  
+  if('string' == typeof map) {
+    var key = map
+    return function (data) { return data[key] }
+  }
+  return map
+}
+
+function id (item) {
+  return item
+}
+
 var k = 0
@@ -5,7 +17,3 @@ var map = exports.map =
   var _k = k++
-  if('string' == typeof map) {
-    var key = map
-    map = function (data) { return data[key] }
-  }
-  map = map || function (e) {return e}
+  map = prop(map) || id
   return function (end, cb) {
@@ -25,3 +33,3 @@ read(end, function (end, data) {
     test = test.test.bind(test)
-  test = test || function (data) {return !!data}
+  test = prop(test) || id
   return function next (end, cb) {
@@ -75,2 +83,17 @@ read(end, function (end, data) {
 
+var unique = exports.unique = function (read, field, invert) {
+  field = prop(field) || id
+  var seen = {}
+  return filter(read, function (data) {
+    var key = field(data)
+    if(seen[key]) return !!invert //false, by default
+    else seen[key] = true
+    return !invert //true by default
+  })
+}
+
+var nonUnique = exports.nonUnique = function (read, field) {
+  return unique(read, field, true)
+}
+
 var nextTick = process.nextTick
@@ -77,0 +100,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

25786

increased by5.45%

Number of package files

18

increased by5.88%

Lines of code

595

increased by7.01%

No dependency changes