diff --git a/src/Pipes.Node.Stream.purs b/src/Pipes.Node.Stream.purs
index 5cc5a5e..39b9db1 100644
--- a/src/Pipes.Node.Stream.purs
+++ b/src/Pipes.Node.Stream.purs
@@ -112,7 +112,6 @@ fromTransform t =
       needsDrain <- liftEffect $ O.needsDrain t
       if needsDrain then do
         liftAff $ delay $ wrap 0.0
-        liftAff $ O.awaitReadableOrClosed t
         yieldWhileReadable
         pure $ Loop {error, cancel}
       else do