From 4d03f100b79f7653de0fbb62a3f5ca9102ed2646 Mon Sep 17 00:00:00 2001
From: Stephen <stephband@cruncher.ch>
Date: Tue, 9 Jul 2024 20:17:18 +0200
Subject: [PATCH] Stream support

---
 modules/renderer/renderer.js | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/modules/renderer/renderer.js b/modules/renderer/renderer.js
index d14e0cb..3bfef3b 100644
--- 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; }