import { StreamInternal } from "@effect/core/stream/Stream/operations/_internal/StreamInternal"

/**
 * Creates a stream from an effect producing a value of type `A` or an empty
 * `Stream`.
 *
 * @tsplus static effect/core/stream/Stream.Ops fromEffectMaybe
 */
export function fromEffectMaybe<R, E, A>(effect: Effect<R, Maybe<E>, A>): Stream<R, E, A> {
  return new StreamInternal(
    Channel.unwrap(
      effect.fold(
        (option) => option.fold(Channel.unit, (e) => Channel.fail(e)),
        (a) => Channel.write(Chunk.single(a))
      )
    )
  )
}