From edc7d40dbc92c4a32d3c16745a69d6b12fbfda67 Mon Sep 17 00:00:00 2001
From: Orion Kindel <orionkindel@gmail.com>
Date: Tue, 14 May 2024 11:04:48 -0500
Subject: [PATCH] wip: explore removing delays(7)

---
 src/Pipes.Node.Stream.purs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/Pipes.Node.Stream.purs b/src/Pipes.Node.Stream.purs
index 8141400..bf451d6 100644
--- a/src/Pipes.Node.Stream.purs
+++ b/src/Pipes.Node.Stream.purs
@@ -108,6 +108,7 @@ fromTransform t =
       err <- liftEffect $ liftST $ STRef.read error
       for_ err throwError
 
+      yieldWhileReadable
       ma <- await
       case ma of
         Nothing -> cleanup cancel