wip: explore removing delays(7)

2024-05-14 11:04:48 -05:00 · 2024-05-14 11:04:48 -05:00 · edc7d40dbc
commit edc7d40dbc
parent ba8d90038d
1 changed files with 1 additions and 0 deletions
--- 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