//#region src/utils/streams.d.ts
/**
 * Stream / async-iterable helpers. All helpers honor `AbortSignal`
 * propagation: when the supplied signal aborts, the underlying
 * iterator's `return()` method is invoked so that resources held by the
 * upstream generator are released cleanly.
 *
 * @packageDocumentation
 */
/**
 * Drain an `AsyncIterable` into an array.
 *
 * @stable
 */
declare function collect<T>(source: AsyncIterable<T>, signal?: AbortSignal): Promise<T[]>;
/**
 * Map every value of an async iterable. The mapper may be async.
 * Cancellation via `signal` is honored.
 *
 * @stable
 */
declare function mapStream<T, U>(source: AsyncIterable<T>, fn: (value: T, index: number) => U | Promise<U>, signal?: AbortSignal): AsyncIterable<U>;
/**
 * Filter values produced by `source`. The predicate may be async.
 *
 * @stable
 */
declare function filter<T>(source: AsyncIterable<T>, pred: (value: T, index: number) => boolean | Promise<boolean>, signal?: AbortSignal): AsyncIterable<T>;
/**
 * Take the first `n` items.
 *
 * @stable
 */
declare function take<T>(source: AsyncIterable<T>, n: number, signal?: AbortSignal): AsyncIterable<T>;
/**
 * Take items as long as `pred` returns truthy. The first item for which
 * `pred` returns falsy ends the stream.
 *
 * @stable
 */
declare function takeWhile<T>(source: AsyncIterable<T>, pred: (value: T, index: number) => boolean | Promise<boolean>, signal?: AbortSignal): AsyncIterable<T>;
/**
 * Merge multiple async iterables into a single output iterable. Items
 * are yielded in the order they arrive (interleaved), not in source
 * order. Cancellation propagates to every upstream iterator.
 *
 * @stable
 */
declare function merge<T>(sources: ReadonlyArray<AsyncIterable<T>>, signal?: AbortSignal): AsyncIterable<T>;
/**
 * Wrap `source` with abort-signal propagation: when `signal` aborts the
 * underlying iterator's `return()` is called and the loop exits cleanly.
 *
 * @stable
 */
declare function withSignal<T>(source: AsyncIterable<T>, signal?: AbortSignal): AsyncIterable<T>;
//#endregion
export { collect, filter, mapStream, merge, take, takeWhile, withSignal };
//# sourceMappingURL=streams.d.ts.map