import * as M from "../Managed";
import * as T from "../Task";
import * as Sink from "./internal/Sink";
import type { Stream } from "./model";
/**
 * Runs the sink on the stream to produce either the sink's result or an error.
 */
export declare const runManaged_: <R, E, A, R1, E1, B>(
   stream: Stream<R, E, A>,
   sink: Sink.Sink<R1, E1, A, any, B>
) => M.Managed<R & R1, E | E1, B>;
/**
 * Runs the sink on the stream to produce either the sink's result or an error.
 */
export declare const runManaged: <A, R1, E1, B>(
   sink: Sink.Sink<R1, E1, A, any, B>
) => <R, E>(stream: Stream<R, E, A>) => M.Managed<R & R1, E1 | E, B>;
/**
 * Runs the sink on the stream to produce either the sink's result or an error.
 */
export declare const run_: <R, E, A, R1, E1, B>(
   stream: Stream<R, E, A>,
   sink: Sink.Sink<R1, E1, A, any, B>
) => T.Task<R & R1, E | E1, B>;
/**
 * Runs the sink on the stream to produce either the sink's result or an error.
 */
export declare const run: <A, R1, E1, B>(
   sink: Sink.Sink<R1, E1, A, any, B>
) => <R, E>(stream: Stream<R, E, A>) => T.Task<R & R1, E1 | E, B>;
export declare const runCollect: <R, E, A>(stream: Stream<R, E, A>) => T.Task<R, E, readonly A[]>;
/**
 * Runs the stream and collects all of its elements to an array.
 */
export declare const runDrain: <R, E, A>(stream: Stream<R, E, A>) => T.Task<R, E, void>;
/**
 * Consumes all elements of the stream, passing them to the specified callback.
 */
export declare const foreach_: <R, E, A, R1, E1, B>(
   stream: Stream<R, E, A>,
   f: (a: A) => T.Task<R1, E1, B>
) => T.Task<R & R1, E | E1, void>;
/**
 * Consumes all elements of the stream, passing them to the specified callback.
 */
export declare const foreach: <A, R1, E1, B>(
   f: (a: A) => T.Task<R1, E1, B>
) => <R, E>(stream: Stream<R, E, A>) => T.Task<R & R1, E1 | E, void>;
/**
 * Like `foreach`, but returns a `Managed` so the finalization order
 * can be controlled.
 */
export declare const foreachManaged_: <R, E, A, R1, E1, B>(
   stream: Stream<R, E, A>,
   f: (a: A) => T.Task<R1, E1, B>
) => M.Managed<R & R1, E | E1, void>;
/**
 * Like `foreach`, but returns a `Managed` so the finalization order
 * can be controlled.
 */
export declare const foreachManaged: <A, R1, E1, B>(
   f: (a: A) => T.Task<R1, E1, B>
) => <R, E>(stream: Stream<R, E, A>) => M.Managed<R & R1, E1 | E, void>;
//# sourceMappingURL=destructors.d.ts.map