/** * Creates a stream from an effect producing chunks of `A` values until it * fails with `None`. * * @tsplus static effect/core/stream/Stream.Ops repeatEffectChunkMaybe */ export function repeatEffectChunkMaybe( effect: Effect, Chunk> ): Stream { return Stream.unfoldChunkEffect(effect, (eff) => eff .map((chunk) => Maybe.some([chunk, eff] as const)) .catchAll((option) => option.fold(Effect.none, (e) => Effect.fail(e)))) }