vega-dataflow - npm Package Compare versions

Comparing version 1.2.6 to 1.2.7

package.json

 {
   "name": "vega-dataflow",
-  "version": "1.2.6",
+  "version": "1.2.7",
   "description": "Vega streaming dataflow graph.",
@@ -5,0 +5,0 @@ "repository": {

src/DataSource.js

@@ -170,2 +170,6 @@ var log = require('vega-logging'),
 
+    if (delta.sort) {
+      ds._data.sort(delta.sort);
+    }
+
     // if reflowing, add any other tuples not currently in changeset
@@ -172,0 +176,0 @@ if (input.reflow) {

src/Graph.js

@@ -202,3 +202,3 @@ var dl = require('datalib'),
 prototype.connect = function(branch) {
-  var collector, node, data, signals, i, n, j, m;
+  var collector, node, data, signals, i, n, j, m, x, y;
 
@@ -212,3 +212,7 @@ // connect the pipeline
     for (j=0, m=data.length; j<m; ++j) {
-      this.data(data[j]).addListener(collector);
+      if (!(x=this.data(y=data[j]))) {
+        throw new Error('Unknown data source ' + dl.str(y));
+      }
+
+      x.addListener(collector);
     }
@@ -218,3 +222,7 @@
     for (j=0, m=signals.length; j<m; ++j) {
-      this.signal(signals[j]).addListener(collector);
+      if (!(x=this.signal(y=signals[j]))) {
+        throw new Error('Unknown signal ' + dl.str(y));
+      }
+
+      x.addListener(collector);
     }
@@ -221,0 +229,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

522121

increased by0.21%

Lines of code

7000

increased by0.29%

No dependency changes