import { Effect } from "@effect/core/io/Effect/definition"; import { Maybe } from "@tsplus/stdlib/data/Maybe/definition"; import { Chunk } from "@tsplus/stdlib/collections/Chunk/definition"; import { Exit } from "@effect/core/io/Exit/definition"; import { Cause } from "@effect/core/io/Cause/definition"; /** * @tsplus type effect/core/stream/Stream/Emit */ export interface Emit extends EmitOps { (f: Effect, Chunk>): Promise; } /** * @tsplus type effect/core/stream/Stream/Emit.Ops */ export interface EmitOperations { } export declare const Emit: EmitOperations; export interface EmitOps { /** * Emits a chunk containing the specified values. */ readonly chunk: (as: Chunk) => Promise; /** * Terminates with a cause that dies with the specified `Throwable`. */ readonly die: (err: Err) => Promise; /** * Terminates with a cause that dies with a `Throwable` with the specified * message. */ readonly dieMessage: (message: string) => Promise; /** * Either emits the specified value if this `Exit` is a `Success` or else * terminates with the specified cause if this `Exit` is a `Failure`. */ readonly done: (exit: Exit) => Promise; /** * Terminates with an end of stream signal. */ readonly end: () => Promise; /** * Terminates with the specified error. */ readonly fail: (e: E) => Promise; /** * Either emits the success value of this effect or terminates the stream * with the failure value of this effect. */ readonly fromEffect: (io: Effect) => Promise; /** * Either emits the success value of this effect or terminates the stream * with the failure value of this effect. */ readonly fromEffectChunk: (io: Effect>) => Promise; /** * Terminates the stream with the specified cause. */ readonly halt: (cause: Cause) => Promise; /** * Emits a chunk containing the specified value. */ readonly single: (a: A) => Promise; } /** * @tsplus static effect/core/stream/Stream/Emit.Ops __call * @tsplus location "@effect/core/stream/Stream/Emit" */ export declare function apply(fn: (f: Effect, Chunk>) => Promise): Emit; //# sourceMappingURL=Emit.d.ts.map