wip: explore removing delays(10)

2024-05-14 12:44:31 -05:00 · 2024-05-14 12:44:31 -05:00 · 0ef7240d61
commit 0ef7240d61
parent de22f44f86
1 changed files with 0 additions and 1 deletions
--- 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