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