effect-io-ai

Package: effect
Module: Stream

Stream.failCause

Creates a stream that fails with the specified Cause.

Example (Failing with a cause)

import { Cause, Console, Effect, Stream } from "effect"

const stream = Stream.failCause(Cause.fail("Database connection failed")).pipe(
  Stream.catchCause(() => Stream.succeed("recovered"))
)

const program = Effect.gen(function*() {
  const values = yield* Stream.runCollect(stream)
  yield* Console.log(values)
  // Output: [ "recovered" ]
})

Effect.runPromise(program)

Signature

declare const failCause: <E>(cause: Cause.Cause<E>) => Stream<never, E>

Source

Since v2.0.0