effect-io-ai

Package: effect
Module: Sink

Sink.failCause

Creates a sink halting with a specified Cause.

Example (Failing with a cause)

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

// Create a sink that fails with a specific cause
const sink = Sink.failCause(Cause.fail(new Error("Custom cause")))

// Use it with a stream
const stream = Stream.make(1, 2, 3)
const program = Stream.run(stream, sink)

Effect.runPromise(program).catch(console.log)
// Output: Error: Custom cause

Signature

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

Source

Since v2.0.0