From 657af14bb6f461e5def017d8d1ca6142b00891cb Mon Sep 17 00:00:00 2001
From: Orion Kindel <orionkindel@gmail.com>
Date: Tue, 14 May 2024 14:07:20 -0500
Subject: [PATCH] fix: await finished before exiting

---
 src/Pipes.Node.Stream.purs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/Pipes.Node.Stream.purs b/src/Pipes.Node.Stream.purs
index 39d1af3..e690026 100644
--- a/src/Pipes.Node.Stream.purs
+++ b/src/Pipes.Node.Stream.purs
@@ -94,10 +94,10 @@ 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
+      liftAff $ O.awaitFinished t
       fromReadable t
+      liftEffect $ removeErrorListener
       pure $ Done unit
 
     yieldWhileReadable = do