Stream support

stephband · Jul 9, 2024 · 4d03f10 · 4d03f10
1 parent 7ef0edf
commit 4d03f10
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/modules/renderer/renderer.js b/modules/renderer/renderer.js
@@ -74,7 +74,10 @@ function renderValue(renderer, args, values, n, object, isRender = false) {
             return;
         }
 
-        /*
+        //if (Signal.isSignal(target)) {
+        //    //
+        //}
+
         // Is target a pipeable Stream?
         if (target.pipe) {
             const streams = renderer.streams || (renderer.streams = []);
@@ -88,6 +91,7 @@ function renderValue(renderer, args, values, n, object, isRender = false) {
             return;
         }
 
+        /*
         // Is target a Stream that is already consumed, and therefore does not
         // have .pipe()? We still want to stop it when the renderer is
         // destroyed, but we don't want to renderer anything.
@@ -237,7 +241,7 @@ export default class Renderer {
 
         uncue(this);
         stopPromises(this.promises);
-        //stopStreams(this.streams);
+        this.streams && this.streams.forEach(callStop);
 
         if (window.DEBUG) { --Renderer.count; }