steampipes - npm Package Compare versions

Comparing version 6.0.0 to 6.1.0

lib/experiments/tests/tees.test.js

@@ -1,2 +0,1 @@
-// Generated by CoffeeScript 2.5.1
 (function() {
@@ -40,3 +39,3 @@ //###########################################################################################################
   //...........................................................................................................
-  SP = require('../..');
+  SP = require('../../..');
 
@@ -219,3 +218,1 @@ ({$, $async} = SP);
 }).call(this);
-
-//# sourceMappingURL=tees.test.js.map

lib/standard-transforms.js

@@ -340,2 +340,20 @@ (function() {
 
+  //-----------------------------------------------------------------------------------------------------------
+  this.$tee = function(bystream) {
+    var last, pipeline, source;
+    source = this.new_push_source();
+    last = Symbol('last');
+    pipeline = [];
+    pipeline.push(source);
+    pipeline.push(bystream);
+    this.pull(...pipeline);
+    return $({last}, (d, send) => {
+      if (d === last) {
+        return source.end();
+      }
+      source.send(d);
+      return send(d);
+    });
+  };
+
 }).call(this);

lib/tests/modifiers.test.js

@@ -0,1 +1,2 @@
+// Generated by CoffeeScript 2.5.1
 (function() {
@@ -251,1 +252,3 @@ 'use strict';
 }).call(this);
+
+//# sourceMappingURL=modifiers.test.js.map

package.json

 {
   "name": "steampipes",
-  "version": "6.0.0",
+  "version": "6.1.0",
   "description": "Fast, simple data pipelines",
@@ -5,0 +5,0 @@ "main": "lib/main.js",

README.md

@@ -304,3 +304,6 @@
   using modifiers instead (`$ { once: [ 'first', 'last', ], }, transform (d, send ) ->`) to avoid API bloat
+* [ ] implement tees which are like branching tracks that lead to their own sinks; there should also
+  be parallel tracks that are rejoined later on
 
+
 ### Future: JS Pipeline Operator
@@ -307,0 +310,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

1085980

increased by0.36%

Lines of code

8017

increased by0.21%

Number of lines in readme file

379

increased by0.8%

No dependency changes