@syndicate-lang/driver-streams-node - npm Package Compare versions

Comparing version 0.2.7 to 0.2.8

lib/buffer.js

@@ -204,2 +204,3 @@ "use strict";
   _Syndicate.bootModule(module);
-}
+}
+

lib/duplex.js

@@ -97,2 +97,3 @@ "use strict";
   _Syndicate.bootModule(module);
-}
+}
+

lib/index.js

@@ -39,2 +39,3 @@ "use strict"; //---------------------------------------------------------------------------
   _Syndicate.bootModule(module);
-}
+}
+

lib/net.js

@@ -930,2 +930,3 @@ "use strict";
   _Syndicate.bootModule(module);
-}
+}
+

lib/streams.js

@@ -177,60 +177,73 @@ "use strict";
 
-  _Dataspace._currentFacet.addEndpoint(function () {
-    var _c20 = (0, _core.Observe)(Stream(id, End()));
+  {
+    var _facets2 = _Syndicate.Map();
 
-    var _assn = _Syndicate.Observe(_c20);
+    _Dataspace._currentFacet.addEndpoint(function () {
+      var _c21 = (0, _core.Observe)(Stream(id, End()));
 
-    var _handler = {
-      skeleton: null,
-      constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-      constVals: _Syndicate.fromJS([_c20]),
-      capturePaths: _Syndicate.fromJS([]),
-      assertion: _assn,
-      callback: _Dataspace.wrap(function (_evt, _vs) {
-        if (_evt === _Skeleton.EVENT_ADDED) {
-          _Dataspace._currentFacet.actor.scheduleScript(function () {
-            _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
-              var _this = this;
+      var _assn = _Syndicate.Observe(_c21);
 
-              _Dataspace._currentFacet.addEndpoint(function () {
-                var _c21 = (0, _core.Observe)(Stream(id, End()));
+      var _handler = {
+        skeleton: null,
+        constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
+        constVals: _Syndicate.fromJS([_c21]),
+        capturePaths: _Syndicate.fromJS([]),
+        assertion: _assn,
+        callback: _Dataspace.wrap(function (_evt, _vs) {
+          if (_evt === _Skeleton.EVENT_ADDED) {
+            _Dataspace._currentFacet.actor.scheduleScript(function () {
+              _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
+                var _this = this;
 
-                var _assn2 = _Syndicate.Observe(_c21);
+                _facets2 = _facets2.set(_Syndicate.fromJS([]), _Dataspace._currentFacet);
 
-                var _handler2 = {
-                  skeleton: null,
-                  constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-                  constVals: _Syndicate.fromJS([_c21]),
-                  capturePaths: _Syndicate.fromJS([]),
-                  assertion: _assn2,
-                  callback: _Dataspace.wrap(function (_evt2, _vs2) {
-                    if (_evt2 === _Skeleton.EVENT_REMOVED) {
-                      _Dataspace._currentFacet.actor.scheduleScript(function () {
-                        _Dataspace._currentFacet.stop(function () {
-                          ;
-                        });
-                      });
-                    }
-                  })
-                };
-                return [_assn2, _handler2];
-              }, false);
+                _Dataspace._currentFacet.addDataflow(function () {
+                  void 0;
+                });
 
+                {
+                  _Dataspace._currentFacet.addStartScript(function () {
+                    _this.endMonitorExists = true;
+                  });
+
+                  _Dataspace._currentFacet.addStopScript(function () {
+                    this.endMonitorExists = false;
+                  });
+                }
+              }, true);
+            });
+          }
+        })
+      };
+      return [_assn, _handler];
+    }, true);
+
+    _Dataspace._currentFacet.addEndpoint(function () {
+      var _c22 = (0, _core.Observe)(Stream(id, End()));
+
+      var _assn2 = _Syndicate.Observe(_c22);
+
+      var _handler2 = {
+        skeleton: null,
+        constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
+        constVals: _Syndicate.fromJS([_c22]),
+        capturePaths: _Syndicate.fromJS([]),
+        assertion: _assn2,
+        callback: _Dataspace.wrap(function (_evt2, _vs2) {
+          if (_evt2 === _Skeleton.EVENT_REMOVED) {
+            _Dataspace._currentFacet.actor.scheduleScript(function () {
               {
-                _Dataspace._currentFacet.addStartScript(function () {
-                  _this.endMonitorExists = true;
-                });
+                var _key2 = _Syndicate.fromJS([]);
 
-                _Dataspace._currentFacet.addStopScript(function () {
-                  this.endMonitorExists = false;
-                });
+                _facets2.get(_key2).stop();
+
+                _facets2 = _facets2.remove(_key2);
               }
-            }, true);
-          });
-        }
-      })
-    };
-    return [_assn, _handler];
-  }, true);
-
+            });
+          }
+        })
+      };
+      return [_assn2, _handler2];
+    }, true);
+  }
   s.on('end', _core.Dataspace.wrapExternal(function () {
@@ -263,5 +276,5 @@ if (_this2.endMonitorExists) {
   _Dataspace._currentFacet.addEndpoint(function () {
-    var _c22 = id;
+    var _c23 = id;
 
-    var _assn3 = _Syndicate.Observe(Stream(_c22, Pushback(_Syndicate.Capture(_Syndicate.Discard._instance))));
+    var _assn3 = _Syndicate.Observe(Stream(_c23, Pushback(_Syndicate.Capture(_Syndicate.Discard._instance))));
 
@@ -271,3 +284,3 @@ var _handler3 = {
       constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
-      constVals: _Syndicate.fromJS([_c22]),
+      constVals: _Syndicate.fromJS([_c23]),
       capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0])]),
@@ -290,109 +303,125 @@ assertion: _assn3,
 
-  _Dataspace._currentFacet.addEndpoint(function () {
-    var _c25 = id;
+  {
+    var _facets4 = _Syndicate.Map();
 
-    var _assn4 = _Syndicate.Observe(Stream(_c25, BackPressure(_Syndicate.Capture(_Syndicate.Discard._instance))));
+    _Dataspace._currentFacet.addEndpoint(function () {
+      var _c27 = id;
 
-    var _handler4 = {
-      skeleton: [Stream.constructorInfo, null, [BackPressure.constructorInfo, null]],
-      constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
-      constVals: _Syndicate.fromJS([_c25]),
-      capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0])]),
-      assertion: _assn4,
-      callback: _Dataspace.wrap(function (_evt4, _vs4) {
-        if (_evt4 === _Skeleton.EVENT_ADDED) {
-          var _writable = _vs4.get(0);
+      var _assn4 = _Syndicate.Observe(Stream(_c27, BackPressure(_Syndicate.Capture(_Syndicate.Discard._instance))));
 
-          _Dataspace._currentFacet.actor.scheduleScript(function () {
-            _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
-              _Dataspace._currentFacet.addEndpoint(function () {
-                var _c26 = Stream(id, BackPressure(_writable));
+      var _handler4 = {
+        skeleton: [Stream.constructorInfo, null, [BackPressure.constructorInfo, null]],
+        constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
+        constVals: _Syndicate.fromJS([_c27]),
+        capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0])]),
+        assertion: _assn4,
+        callback: _Dataspace.wrap(function (_evt4, _vs4) {
+          if (_evt4 === _Skeleton.EVENT_ADDED) {
+            var _writable = _vs4.get(0);
 
-                var _assn5 = _Syndicate.Observe(_c26);
+            _Dataspace._currentFacet.actor.scheduleScript(function () {
+              _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
+                _facets4 = _facets4.set(_Syndicate.fromJS([_writable]), _Dataspace._currentFacet);
 
-                var _handler5 = {
-                  skeleton: null,
-                  constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-                  constVals: _Syndicate.fromJS([_c26]),
-                  capturePaths: _Syndicate.fromJS([]),
-                  assertion: _assn5,
-                  callback: _Dataspace.wrap(function (_evt5, _vs5) {
-                    if (_evt5 === _Skeleton.EVENT_REMOVED) {
-                      _Dataspace._currentFacet.actor.scheduleScript(function () {
-                        _Dataspace._currentFacet.stop(function () {
-                          ;
-                        });
-                      });
-                    }
-                  })
-                };
-                return [_assn5, _handler5];
-              }, false);
+                _Dataspace._currentFacet.addDataflow(function () {
+                  void 0;
+                });
 
-              {
-                _Dataspace._currentFacet.addEndpoint(function () {
-                  var _this4 = this;
+                {
+                  _Dataspace._currentFacet.addEndpoint(function () {
+                    var _this4 = this;
 
-                  var _c27 = _writable;
+                    var _c28 = _writable;
 
-                  var _assn6 = _Syndicate.Observe(Stream(_c27, Window(_Syndicate.Capture(_Syndicate.Discard._instance), _Syndicate.Capture(_Syndicate.Discard._instance))));
+                    var _assn5 = _Syndicate.Observe(Stream(_c28, Window(_Syndicate.Capture(_Syndicate.Discard._instance), _Syndicate.Capture(_Syndicate.Discard._instance))));
 
-                  var _handler6 = {
-                    skeleton: [Stream.constructorInfo, null, [Window.constructorInfo, null, null]],
-                    constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
-                    constVals: _Syndicate.fromJS([_c27]),
-                    capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0]), _Syndicate.fromJS([1, 1])]),
-                    assertion: _assn6,
-                    callback: _Dataspace.wrap(function (_evt6, _vs6) {
-                      if (_evt6 === _Skeleton.EVENT_ADDED) {
-                        var _seqno = _vs6.get(0);
+                    var _handler5 = {
+                      skeleton: [Stream.constructorInfo, null, [Window.constructorInfo, null, null]],
+                      constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
+                      constVals: _Syndicate.fromJS([_c28]),
+                      capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0]), _Syndicate.fromJS([1, 1])]),
+                      assertion: _assn5,
+                      callback: _Dataspace.wrap(function (_evt5, _vs5) {
+                        if (_evt5 === _Skeleton.EVENT_ADDED) {
+                          var _seqno = _vs5.get(0);
 
-                        var _amount = _vs6.get(1);
+                          var _amount = _vs5.get(1);
 
-                        _Dataspace._currentFacet.actor.scheduleScript(function () {
-                          {
-                            // Attend to `seqno` to allow otherwise-noop changes to
-                            // refresh the outboundWindow size.
-                            _this4.outboundWindows = _this4.outboundWindows.set(_writable, _amount);
-                          }
-                        });
-                      }
-                    })
-                  };
-                  return [_assn6, _handler6];
-                }, true);
+                          _Dataspace._currentFacet.actor.scheduleScript(function () {
+                            {
+                              // Attend to `seqno` to allow otherwise-noop changes to
+                              // refresh the outboundWindow size.
+                              _this4.outboundWindows = _this4.outboundWindows.set(_writable, _amount);
+                            }
+                          });
+                        }
+                      })
+                    };
+                    return [_assn5, _handler5];
+                  }, true);
 
-                _Dataspace._currentFacet.addEndpoint(function () {
-                  var _this5 = this;
+                  _Dataspace._currentFacet.addEndpoint(function () {
+                    var _this5 = this;
 
-                  var _c28 = _writable;
+                    var _c29 = _writable;
 
-                  var _assn7 = _Syndicate.Observe(Stream(_c28, Window(_Syndicate.Discard._instance, _Syndicate.Discard._instance)));
+                    var _assn6 = _Syndicate.Observe(Stream(_c29, Window(_Syndicate.Discard._instance, _Syndicate.Discard._instance)));
 
-                  var _handler7 = {
-                    skeleton: [Stream.constructorInfo, null, [Window.constructorInfo, null, null]],
-                    constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
-                    constVals: _Syndicate.fromJS([_c28]),
-                    capturePaths: _Syndicate.fromJS([]),
-                    assertion: _assn7,
-                    callback: _Dataspace.wrap(function (_evt7, _vs7) {
-                      if (_evt7 === _Skeleton.EVENT_REMOVED) {
-                        _Dataspace._currentFacet.actor.scheduleScript(function () {
-                          {
-                            _this5.outboundWindows = _this5.outboundWindows.remove(_writable);
-                          }
-                        });
-                      }
-                    })
-                  };
-                  return [_assn7, _handler7];
-                }, true);
+                    var _handler6 = {
+                      skeleton: [Stream.constructorInfo, null, [Window.constructorInfo, null, null]],
+                      constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
+                      constVals: _Syndicate.fromJS([_c29]),
+                      capturePaths: _Syndicate.fromJS([]),
+                      assertion: _assn6,
+                      callback: _Dataspace.wrap(function (_evt6, _vs6) {
+                        if (_evt6 === _Skeleton.EVENT_REMOVED) {
+                          _Dataspace._currentFacet.actor.scheduleScript(function () {
+                            {
+                              _this5.outboundWindows = _this5.outboundWindows.remove(_writable);
+                            }
+                          });
+                        }
+                      })
+                    };
+                    return [_assn6, _handler6];
+                  }, true);
+                }
+              }, true);
+            });
+          }
+        })
+      };
+      return [_assn4, _handler4];
+    }, true);
+
+    _Dataspace._currentFacet.addEndpoint(function () {
+      var _c30 = id;
+
+      var _assn7 = _Syndicate.Observe(Stream(_c30, BackPressure(_Syndicate.Capture(_Syndicate.Discard._instance))));
+
+      var _handler7 = {
+        skeleton: [Stream.constructorInfo, null, [BackPressure.constructorInfo, null]],
+        constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
+        constVals: _Syndicate.fromJS([_c30]),
+        capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0])]),
+        assertion: _assn7,
+        callback: _Dataspace.wrap(function (_evt7, _vs7) {
+          if (_evt7 === _Skeleton.EVENT_REMOVED) {
+            var _writable2 = _vs7.get(0);
+
+            _Dataspace._currentFacet.actor.scheduleScript(function () {
+              {
+                var _key4 = _Syndicate.fromJS([_writable2]);
+
+                _facets4.get(_key4).stop();
+
+                _facets4 = _facets4.remove(_key4);
               }
-            }, true);
-          });
-        }
-      })
-    };
-    return [_assn4, _handler4];
-  }, true);
+            });
+          }
+        })
+      };
+      return [_assn7, _handler7];
+    }, true);
+  }
 
@@ -418,80 +447,94 @@ _Dataspace.declareField(this, "outboundWindow", null);
 
-  _Dataspace._currentFacet.addEndpoint(function () {
-    var _c31 = id;
+  {
+    var _facets6 = _Syndicate.Map();
 
-    var _assn8 = _Syndicate.Observe((0, _core.Observe)(Stream(_c31, Data(_Syndicate.Discard._instance))));
+    _Dataspace._currentFacet.addEndpoint(function () {
+      var _c34 = id;
 
-    var _handler8 = {
-      skeleton: [_core.Observe.constructorInfo, [Stream.constructorInfo, null, [Data.constructorInfo, null]]],
-      constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
-      constVals: _Syndicate.fromJS([_c31]),
-      capturePaths: _Syndicate.fromJS([]),
-      assertion: _assn8,
-      callback: _Dataspace.wrap(function (_evt8, _vs8) {
-        if (_evt8 === _Skeleton.EVENT_ADDED) {
-          _Dataspace._currentFacet.actor.scheduleScript(function () {
-            _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
-              _Dataspace._currentFacet.addEndpoint(function () {
-                var _c32 = id;
+      var _assn8 = _Syndicate.Observe((0, _core.Observe)(Stream(_c34, Data(_Syndicate.Discard._instance))));
 
-                var _assn9 = _Syndicate.Observe((0, _core.Observe)(Stream(_c32, Data(_Syndicate.Discard._instance))));
+      var _handler8 = {
+        skeleton: [_core.Observe.constructorInfo, [Stream.constructorInfo, null, [Data.constructorInfo, null]]],
+        constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
+        constVals: _Syndicate.fromJS([_c34]),
+        capturePaths: _Syndicate.fromJS([]),
+        assertion: _assn8,
+        callback: _Dataspace.wrap(function (_evt8, _vs8) {
+          if (_evt8 === _Skeleton.EVENT_ADDED) {
+            _Dataspace._currentFacet.actor.scheduleScript(function () {
+              _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
+                _facets6 = _facets6.set(_Syndicate.fromJS([]), _Dataspace._currentFacet);
 
-                var _handler9 = {
-                  skeleton: [_core.Observe.constructorInfo, [Stream.constructorInfo, null, [Data.constructorInfo, null]]],
-                  constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
-                  constVals: _Syndicate.fromJS([_c32]),
-                  capturePaths: _Syndicate.fromJS([]),
-                  assertion: _assn9,
-                  callback: _Dataspace.wrap(function (_evt9, _vs9) {
-                    if (_evt9 === _Skeleton.EVENT_REMOVED) {
-                      _Dataspace._currentFacet.actor.scheduleScript(function () {
-                        _Dataspace._currentFacet.stop(function () {
-                          ;
-                        });
-                      });
-                    }
-                  })
-                };
-                return [_assn9, _handler9];
-              }, false);
-
-              {
                 _Dataspace._currentFacet.addDataflow(function () {
-                  var _this6 = this;
+                  void 0;
+                });
 
-                  {
-                    while (this.readable && (this.outboundWindow === null || this.outboundWindow > 0)) {
-                      var maxlen = this.outboundWindow === null ? void 0 : Math.min(s.readableLength, this.outboundWindow);
+                {
+                  _Dataspace._currentFacet.addDataflow(function () {
+                    var _this6 = this;
 
-                      var _chunk2 = s.read(maxlen);
+                    {
+                      while (this.readable && (this.outboundWindow === null || this.outboundWindow > 0)) {
+                        var maxlen = this.outboundWindow === null ? void 0 : Math.min(s.readableLength, this.outboundWindow);
 
-                      if (_chunk2 === null) {
-                        this.readable = false;
-                      } else {
-                        (function () {
-                          var amount = objectMode ? 1 : _chunk2.length; // This is the adjustment that forces us to pay attention to seqno:
+                        var _chunk2 = s.read(maxlen);
 
-                          _this6.outboundWindows = _this6.outboundWindows.mapEntries(function (_ref) {
-                            var _ref2 = _slicedToArray(_ref, 2),
-                                t = _ref2[0],
-                                c = _ref2[1];
+                        if (_chunk2 === null) {
+                          this.readable = false;
+                        } else {
+                          (function () {
+                            var amount = objectMode ? 1 : _chunk2.length; // This is the adjustment that forces us to pay attention to seqno:
 
-                            return [t, c - amount];
-                          });
-                          if (_this6.outboundWindow !== null) _this6.outboundWindow -= amount;
+                            _this6.outboundWindows = _this6.outboundWindows.mapEntries(function (_ref) {
+                              var _ref2 = _slicedToArray(_ref, 2),
+                                  t = _ref2[0],
+                                  c = _ref2[1];
 
-                          _Dataspace.send(Stream(id, Data(_chunk2)));
-                        })();
+                              return [t, c - amount];
+                            });
+                            if (_this6.outboundWindow !== null) _this6.outboundWindow -= amount;
+
+                            _Dataspace.send(Stream(id, Data(_chunk2)));
+                          })();
+                        }
                       }
                     }
-                  }
-                });
+                  });
+                }
+              }, true);
+            });
+          }
+        })
+      };
+      return [_assn8, _handler8];
+    }, true);
+
+    _Dataspace._currentFacet.addEndpoint(function () {
+      var _c35 = id;
+
+      var _assn9 = _Syndicate.Observe((0, _core.Observe)(Stream(_c35, Data(_Syndicate.Discard._instance))));
+
+      var _handler9 = {
+        skeleton: [_core.Observe.constructorInfo, [Stream.constructorInfo, null, [Data.constructorInfo, null]]],
+        constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
+        constVals: _Syndicate.fromJS([_c35]),
+        capturePaths: _Syndicate.fromJS([]),
+        assertion: _assn9,
+        callback: _Dataspace.wrap(function (_evt9, _vs9) {
+          if (_evt9 === _Skeleton.EVENT_REMOVED) {
+            _Dataspace._currentFacet.actor.scheduleScript(function () {
+              {
+                var _key6 = _Syndicate.fromJS([]);
+
+                _facets6.get(_key6).stop();
+
+                _facets6 = _facets6.remove(_key6);
               }
-            }, true);
-          });
-        }
-      })
-    };
-    return [_assn8, _handler8];
-  }, true);
+            });
+          }
+        })
+      };
+      return [_assn9, _handler9];
+    }, true);
+  }
 }
@@ -513,54 +556,67 @@
 
-  _Dataspace._currentFacet.addEndpoint(function () {
-    var _c35 = id;
+  {
+    var _facets8 = _Syndicate.Map();
 
-    var _assn10 = _Syndicate.Observe((0, _core.Observe)(Stream(_c35, Window(_Syndicate.Discard._instance, _Syndicate.Discard._instance))));
+    _Dataspace._currentFacet.addEndpoint(function () {
+      var _c39 = id;
 
-    var _handler10 = {
-      skeleton: [_core.Observe.constructorInfo, [Stream.constructorInfo, null, [Window.constructorInfo, null, null]]],
-      constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
-      constVals: _Syndicate.fromJS([_c35]),
-      capturePaths: _Syndicate.fromJS([]),
-      assertion: _assn10,
-      callback: _Dataspace.wrap(function (_evt10, _vs10) {
-        if (_evt10 === _Skeleton.EVENT_ADDED) {
-          _Dataspace._currentFacet.actor.scheduleScript(function () {
-            _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
-              _Dataspace._currentFacet.addEndpoint(function () {
-                var _c36 = id;
+      var _assn10 = _Syndicate.Observe((0, _core.Observe)(Stream(_c39, Window(_Syndicate.Discard._instance, _Syndicate.Discard._instance))));
 
-                var _assn11 = _Syndicate.Observe((0, _core.Observe)(Stream(_c36, Window(_Syndicate.Discard._instance, _Syndicate.Discard._instance))));
+      var _handler10 = {
+        skeleton: [_core.Observe.constructorInfo, [Stream.constructorInfo, null, [Window.constructorInfo, null, null]]],
+        constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
+        constVals: _Syndicate.fromJS([_c39]),
+        capturePaths: _Syndicate.fromJS([]),
+        assertion: _assn10,
+        callback: _Dataspace.wrap(function (_evt10, _vs10) {
+          if (_evt10 === _Skeleton.EVENT_ADDED) {
+            _Dataspace._currentFacet.actor.scheduleScript(function () {
+              _Dataspace._currentFacet.actor.addFacet(_Dataspace._currentFacet, function () {
+                _facets8 = _facets8.set(_Syndicate.fromJS([]), _Dataspace._currentFacet);
 
-                var _handler11 = {
-                  skeleton: [_core.Observe.constructorInfo, [Stream.constructorInfo, null, [Window.constructorInfo, null, null]]],
-                  constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
-                  constVals: _Syndicate.fromJS([_c36]),
-                  capturePaths: _Syndicate.fromJS([]),
-                  assertion: _assn11,
-                  callback: _Dataspace.wrap(function (_evt11, _vs11) {
-                    if (_evt11 === _Skeleton.EVENT_REMOVED) {
-                      _Dataspace._currentFacet.actor.scheduleScript(function () {
-                        _Dataspace._currentFacet.stop(function () {
-                          ;
-                        });
-                      });
-                    }
-                  })
-                };
-                return [_assn11, _handler11];
-              }, false);
+                _Dataspace._currentFacet.addDataflow(function () {
+                  void 0;
+                });
 
+                {
+                  _Dataspace._currentFacet.addEndpoint(function () {
+                    return [Stream(id, Window(this.seqno, this.inboundWindow)), null];
+                  }, true);
+                }
+              }, true);
+            });
+          }
+        })
+      };
+      return [_assn10, _handler10];
+    }, true);
+
+    _Dataspace._currentFacet.addEndpoint(function () {
+      var _c40 = id;
+
+      var _assn11 = _Syndicate.Observe((0, _core.Observe)(Stream(_c40, Window(_Syndicate.Discard._instance, _Syndicate.Discard._instance))));
+
+      var _handler11 = {
+        skeleton: [_core.Observe.constructorInfo, [Stream.constructorInfo, null, [Window.constructorInfo, null, null]]],
+        constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
+        constVals: _Syndicate.fromJS([_c40]),
+        capturePaths: _Syndicate.fromJS([]),
+        assertion: _assn11,
+        callback: _Dataspace.wrap(function (_evt11, _vs11) {
+          if (_evt11 === _Skeleton.EVENT_REMOVED) {
+            _Dataspace._currentFacet.actor.scheduleScript(function () {
               {
-                _Dataspace._currentFacet.addEndpoint(function () {
-                  return [Stream(id, Window(this.seqno, this.inboundWindow)), null];
-                }, true);
+                var _key8 = _Syndicate.fromJS([]);
+
+                _facets8.get(_key8).stop();
+
+                _facets8 = _facets8.remove(_key8);
               }
-            }, true);
-          });
-        }
-      })
-    };
-    return [_assn10, _handler10];
-  }, true);
-
+            });
+          }
+        })
+      };
+      return [_assn11, _handler11];
+    }, true);
+  }
   s.on('drain', _core.Dataspace.wrapExternal(function () {
@@ -579,5 +635,5 @@ _this7.inboundWindow = refreshWindow();
 
-    var _c37 = id;
+    var _c41 = id;
 
-    var _assn12 = _Syndicate.Observe(Stream(_c37, Push(_Syndicate.Capture(_Syndicate.Discard._instance), _Syndicate.Capture(_Syndicate.Discard._instance))));
+    var _assn12 = _Syndicate.Observe(Stream(_c41, Push(_Syndicate.Capture(_Syndicate.Discard._instance), _Syndicate.Capture(_Syndicate.Discard._instance))));
 
@@ -587,3 +643,3 @@ var _handler12 = {
       constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
-      constVals: _Syndicate.fromJS([_c37]),
+      constVals: _Syndicate.fromJS([_c41]),
       capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0]), _Syndicate.fromJS([1, 1])]),
@@ -612,5 +668,5 @@ assertion: _assn12,
 
-    var _c38 = id;
+    var _c42 = id;
 
-    var _assn13 = _Syndicate.Observe(Stream(_c38, Close(_Syndicate.Capture(_Syndicate.Discard._instance))));
+    var _assn13 = _Syndicate.Observe(Stream(_c42, Close(_Syndicate.Capture(_Syndicate.Discard._instance))));
 
@@ -620,3 +676,3 @@ var _handler13 = {
       constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
-      constVals: _Syndicate.fromJS([_c38]),
+      constVals: _Syndicate.fromJS([_c42]),
       capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0])]),
@@ -652,5 +708,5 @@ assertion: _assn13,
     _Dataspace._currentFacet.addEndpoint(function () {
-      var _c39 = (0, _core.Observe)(Stream(id, Readable()));
+      var _c43 = (0, _core.Observe)(Stream(id, Readable()));
 
-      var _assn14 = _Syndicate.Observe(_c39);
+      var _assn14 = _Syndicate.Observe(_c43);
 
@@ -660,3 +716,3 @@ var _handler14 = {
         constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-        constVals: _Syndicate.fromJS([_c39]),
+        constVals: _Syndicate.fromJS([_c43]),
         capturePaths: _Syndicate.fromJS([]),
@@ -694,5 +750,5 @@ assertion: _assn14,
     _Dataspace._currentFacet.addEndpoint(function () {
-      var _c40 = (0, _core.Observe)(Stream(id, Writable()));
+      var _c44 = (0, _core.Observe)(Stream(id, Writable()));
 
-      var _assn15 = _Syndicate.Observe(_c40);
+      var _assn15 = _Syndicate.Observe(_c44);
 
@@ -702,3 +758,3 @@ var _handler15 = {
         constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-        constVals: _Syndicate.fromJS([_c40]),
+        constVals: _Syndicate.fromJS([_c44]),
         capturePaths: _Syndicate.fromJS([]),
@@ -736,5 +792,5 @@ assertion: _assn15,
     _Dataspace._currentFacet.addEndpoint(function () {
-      var _c41 = (0, _core.Observe)(Stream(id, Duplex()));
+      var _c45 = (0, _core.Observe)(Stream(id, Duplex()));
 
-      var _assn16 = _Syndicate.Observe(_c41);
+      var _assn16 = _Syndicate.Observe(_c45);
 
@@ -744,3 +800,3 @@ var _handler16 = {
         constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-        constVals: _Syndicate.fromJS([_c41]),
+        constVals: _Syndicate.fromJS([_c45]),
         capturePaths: _Syndicate.fromJS([]),
@@ -791,5 +847,5 @@ assertion: _assn16,
                 _Dataspace._currentFacet.addEndpoint(function () {
-                  var _c48 = _inst2;
+                  var _c52 = _inst2;
 
-                  var _assn18 = _Syndicate.Observe(_c48);
+                  var _assn18 = _Syndicate.Observe(_c52);
 
@@ -799,3 +855,3 @@ var _handler18 = {
                     constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-                    constVals: _Syndicate.fromJS([_c48]),
+                    constVals: _Syndicate.fromJS([_c52]),
                     capturePaths: _Syndicate.fromJS([]),
@@ -809,5 +865,5 @@ assertion: _assn18,
                               _Dataspace._currentFacet.addEndpoint(function () {
-                                var _c49 = _inst2;
+                                var _c53 = _inst2;
 
-                                var _assn19 = _Syndicate.Observe(_c49);
+                                var _assn19 = _Syndicate.Observe(_c53);
 
@@ -817,3 +873,3 @@ var _handler19 = {
                                   constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-                                  constVals: _Syndicate.fromJS([_c49]),
+                                  constVals: _Syndicate.fromJS([_c53]),
                                   capturePaths: _Syndicate.fromJS([]),
@@ -835,5 +891,5 @@ assertion: _assn19,
                               _Dataspace._currentFacet.addEndpoint(function () {
-                                var _c50 = _id2;
+                                var _c54 = _id2;
 
-                                var _assn20 = _Syndicate.Observe((0, _core.Observe)(Stream(_c50, Line(_Syndicate.Discard._instance))));
+                                var _assn20 = _Syndicate.Observe((0, _core.Observe)(Stream(_c54, Line(_Syndicate.Discard._instance))));
 
@@ -843,3 +899,3 @@ var _handler20 = {
                                   constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
-                                  constVals: _Syndicate.fromJS([_c50]),
+                                  constVals: _Syndicate.fromJS([_c54]),
                                   capturePaths: _Syndicate.fromJS([]),
@@ -869,5 +925,5 @@ assertion: _assn20,
                 _Dataspace._currentFacet.addEndpoint(function () {
-                  var _c51 = _id2;
+                  var _c55 = _id2;
 
-                  var _assn21 = _Syndicate.Observe((0, _core.Observe)(Stream(_c51, Line(_Syndicate.Discard._instance))));
+                  var _assn21 = _Syndicate.Observe((0, _core.Observe)(Stream(_c55, Line(_Syndicate.Discard._instance))));
 
@@ -877,3 +933,3 @@ var _handler21 = {
                     constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 0])]),
-                    constVals: _Syndicate.fromJS([_c51]),
+                    constVals: _Syndicate.fromJS([_c55]),
                     capturePaths: _Syndicate.fromJS([]),
@@ -887,5 +943,5 @@ assertion: _assn21,
                               _Dataspace._currentFacet.addEndpoint(function () {
-                                var _c52 = _inst2;
+                                var _c56 = _inst2;
 
-                                var _assn22 = _Syndicate.Observe(_c52);
+                                var _assn22 = _Syndicate.Observe(_c56);
 
@@ -895,3 +951,3 @@ var _handler22 = {
                                   constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-                                  constVals: _Syndicate.fromJS([_c52]),
+                                  constVals: _Syndicate.fromJS([_c56]),
                                   capturePaths: _Syndicate.fromJS([]),
@@ -927,5 +983,5 @@ assertion: _assn22,
                 _Dataspace._currentFacet.addEndpoint(function () {
-                  var _c53 = _Syndicate.Observe(_inst2);
+                  var _c57 = _Syndicate.Observe(_inst2);
 
-                  var _assn23 = _Syndicate.Observe(_c53);
+                  var _assn23 = _Syndicate.Observe(_c57);
 
@@ -935,3 +991,3 @@ var _handler23 = {
                     constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-                    constVals: _Syndicate.fromJS([_c53]),
+                    constVals: _Syndicate.fromJS([_c57]),
                     capturePaths: _Syndicate.fromJS([]),
@@ -958,5 +1014,5 @@ assertion: _assn23,
 
-                    var _c54 = _id2;
+                    var _c58 = _id2;
 
-                    var _assn24 = _Syndicate.Observe(Stream(_c54, Data(_Syndicate.Capture(_Syndicate.Discard._instance))));
+                    var _assn24 = _Syndicate.Observe(Stream(_c58, Data(_Syndicate.Capture(_Syndicate.Discard._instance))));
 
@@ -966,3 +1022,3 @@ var _handler24 = {
                       constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
-                      constVals: _Syndicate.fromJS([_c54]),
+                      constVals: _Syndicate.fromJS([_c58]),
                       capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0])]),
@@ -1014,5 +1070,5 @@ assertion: _assn24,
     _Dataspace._currentFacet.addEndpoint(function () {
-      var _c55 = Incoming(spec);
+      var _c59 = Incoming(spec);
 
-      var _assn25 = _Syndicate.Observe((0, _core.Observe)(Stream(_Syndicate.Discard._instance, _c55)));
+      var _assn25 = _Syndicate.Observe((0, _core.Observe)(Stream(_Syndicate.Discard._instance, _c59)));
 
@@ -1022,3 +1078,3 @@ var _handler25 = {
         constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0, 1])]),
-        constVals: _Syndicate.fromJS([_c55]),
+        constVals: _Syndicate.fromJS([_c59]),
         capturePaths: _Syndicate.fromJS([]),
@@ -1040,5 +1096,5 @@ assertion: _assn25,
     _Dataspace._currentFacet.addEndpoint(function () {
-      var _c56 = id;
+      var _c60 = id;
 
-      var _assn26 = _Syndicate.Observe(Stream(_c56, Rejected(_Syndicate.Capture(_Syndicate.Discard._instance))));
+      var _assn26 = _Syndicate.Observe(Stream(_c60, Rejected(_Syndicate.Capture(_Syndicate.Discard._instance))));
 
@@ -1048,3 +1104,3 @@ var _handler26 = {
         constPaths: _Syndicate.fromJS([_Syndicate.fromJS([0])]),
-        constVals: _Syndicate.fromJS([_c56]),
+        constVals: _Syndicate.fromJS([_c60]),
         capturePaths: _Syndicate.fromJS([_Syndicate.fromJS([1, 0])]),
@@ -1068,5 +1124,5 @@ assertion: _assn26,
     _Dataspace._currentFacet.addEndpoint(function () {
-      var _c57 = (0, _core.Observe)(Stream(id, Duplex()));
+      var _c61 = (0, _core.Observe)(Stream(id, Duplex()));
 
-      var _assn27 = _Syndicate.Observe(_c57);
+      var _assn27 = _Syndicate.Observe(_c61);
 
@@ -1076,3 +1132,3 @@ var _handler27 = {
         constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-        constVals: _Syndicate.fromJS([_c57]),
+        constVals: _Syndicate.fromJS([_c61]),
         capturePaths: _Syndicate.fromJS([]),
@@ -1096,5 +1152,5 @@ assertion: _assn27,
     _Dataspace._currentFacet.addEndpoint(function () {
-      var _c58 = Stream(id, Accepted());
+      var _c62 = Stream(id, Accepted());
 
-      var _assn28 = _Syndicate.Observe(_c58);
+      var _assn28 = _Syndicate.Observe(_c62);
 
@@ -1104,3 +1160,3 @@ var _handler28 = {
         constPaths: _Syndicate.fromJS([_Syndicate.fromJS([])]),
-        constVals: _Syndicate.fromJS([_c58]),
+        constVals: _Syndicate.fromJS([_c62]),
         capturePaths: _Syndicate.fromJS([]),
@@ -1134,2 +1190,3 @@ assertion: _assn28,
   _Syndicate.bootModule(module);
-}
+}
+

lib/subprocess.js

@@ -578,2 +578,3 @@ "use strict";
   _Syndicate.bootModule(module);
-}
+}
+

package.json

 {
   "name": "@syndicate-lang/driver-streams-node",
-  "version": "0.2.7",
+  "version": "0.2.8",
   "description": "Node.js Readable/Writable/Duplex/Transform stream support for Syndicate/js",
@@ -19,3 +19,3 @@ "main": "lib/index.js",
     "@babel/preset-env": "^7.2.0",
-    "@syndicate-lang/syntax": "^0.1.0"
+    "@syndicate-lang/syntax": "^0.1.1"
   },
@@ -26,3 +26,3 @@ "dependencies": {
   },
-  "gitHead": "413f28bf2055fc5453dac609fe5dd19fe9ad618a"
+  "gitHead": "a4d875e03c1f997da01a33ffd34ff672ad0fbdaa"
 }

No alert changes

Improved metrics

Total package byte prevSize

185732

increased by0.57%

Lines of code

3099

increased by1.41%

No dependency changes