.opencode/node_modules/effect/dist/unstable/sql/SqlStream.d.ts

import * as Effect from "../../Effect.ts";
import type * as Scope from "../../Scope.ts";
import * as Stream from "../../Stream.ts";
/**
 * Creates a stream from a callback-style producer with pause and resume
 * callbacks that are triggered when the internal queue applies backpressure.
 *
 * @category constructors
 * @since 4.0.0
 */
export declare const asyncPauseResume: <A, E = never, R = never>(register: (emit: {
    readonly single: (item: A) => void;
    readonly array: (arr: ReadonlyArray<A>) => void;
    readonly fail: (error: E) => void;
    readonly end: () => void;
}) => Effect.Effect<{
    onPause(): void;
    onResume(): void;
}, E, R | Scope.Scope>, bufferSize?: number) => Stream.Stream<A, E, R>;
//# sourceMappingURL=SqlStream.d.ts.map