fix: transform should read more than just 1 chunk after writing

2024-05-13 14:35:44 -05:00 · 2024-05-13 14:35:44 -05:00 · b7bead090e
commit b7bead090e
parent 3db5cc44a9
1 changed files with 1 additions and 1 deletions
--- a/src/Pipes.Node.Stream.purs
+++ b/src/Pipes.Node.Stream.purs
@ -97,7 +97,7 @@ fromTransform t =
    yieldFromReadableHalf = do
      res <- liftEffect (O.read t)
      case res of
-        O.ReadJust a -> yield (Just a)
+        O.ReadJust a -> yield (Just a) *> yieldFromReadableHalf
        O.ReadWouldBlock -> pure unit
        O.ReadClosed -> yield Nothing *> pure unit
    go { error, cancel } = do