(
result: Bun.ReadableStreamDefaultReadManyResult<A>
)
| 53 | return handleResult(result) |
| 54 | } |
| 55 | function handleResult( |
| 56 | result: Bun.ReadableStreamDefaultReadManyResult<A> |
| 57 | ): Pull.Pull<Arr.NonEmptyReadonlyArray<A>, E> { |
| 58 | if (result.done) { |
| 59 | return Cause.done() |
| 60 | } else if (!Arr.isReadonlyArrayNonEmpty(result.value)) { |
| 61 | return readMany() |
| 62 | } |
| 63 | return Effect.succeed(result.value) |
| 64 | } |
| 65 | // @effect-diagnostics-next-line returnEffectInGen:off |
| 66 | return Effect.suspend(readMany) |
| 67 | }))) |