From 7076b13df4fe274df34771ff81337ed3305bce0d Mon Sep 17 00:00:00 2001
From: Orion Kindel <orionkindel@gmail.com>
Date: Tue, 14 May 2024 13:42:39 -0500
Subject: [PATCH] fix: catch incorrect stream implementations

---
 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 afb400f..f7be32f 100644
--- a/src/Pipes.Node.Stream.purs
+++ b/src/Pipes.Node.Stream.purs
@@ -87,6 +87,7 @@ fromTransform :: forall a b m. MonadThrow Error m => MonadAff m => O.Transform a
 fromTransform t =
   let
     cleanup removeErrorListener = do
+      yieldWhileReadable
       liftEffect $ O.end t
       liftEffect $ removeErrorListener
       fromReadable t