/**
 * Optional fluent pipeline helpers layered on top of the explicit collection helpers.
 *
 * @module bquery/concurrency
 */
import type { ConcurrencyPipeline, ConcurrencyPipelineOptions } from './types';
/**
 * Creates an optional fluent pipeline over the existing concurrency collection helpers.
 *
 * The pipeline itself does not create hidden global workers or proxies. Each stage
 * delegates to the already explicit `map()`, `filter()`, `some()`, `every()`,
 * `find()`, and `reduce()` helpers when the pipeline is executed.
 *
 * @example
 * ```ts
 * import { pipeline } from '@bquery/bquery/concurrency';
 *
 * const results = await pipeline([1, 2, 3, 4], {
 *   batchSize: 2,
 *   concurrency: 2,
 * })
 *   .map((value) => value * 2)
 *   .filter((value) => value > 4)
 *   .toArray();
 *
 * console.log(results); // [6, 8]
 * ```
 */
export declare function pipeline<TValue>(values: readonly TValue[], options?: ConcurrencyPipelineOptions): ConcurrencyPipeline<TValue>;
//# sourceMappingURL=pipeline.d.ts.map