import { DEFAULT_DELIMITER, DEFAULT_QUOTATION } from '../../core/constants'; import { CSVBinary, ParseBinaryOptions, ParseOptions } from '../../core/types'; import { InternalEngineConfig } from '../config/InternalEngineConfig'; import { WorkerStrategy } from './WorkerStrategy'; import { WorkerSession } from '../../worker/helpers/WorkerSession'; /** * Worker strategy selector. * * Selects and executes the appropriate worker communication strategy based on engine configuration. * Handles fallback from stream-transfer to message-streaming if needed. * * @internal */ export declare class WorkerStrategySelector { private strategies; constructor(); /** * Register a worker strategy. */ register(strategy: WorkerStrategy): void; /** * Execute with the appropriate strategy based on engine configuration. * * @param input - Input data * @param options - Parse options * @param session - Worker session (can be null) * @param engineConfig - Engine configuration * @returns Async iterable iterator of parsed records */ execute = readonly string[], Delimiter extends string = DEFAULT_DELIMITER, Quotation extends string = DEFAULT_QUOTATION>(input: string | CSVBinary | ReadableStream, options: ParseOptions | ParseBinaryOptions | undefined, session: WorkerSession | null, engineConfig: InternalEngineConfig): AsyncIterableIterator; } /** * Execute parsing with worker strategy. * * @internal */ export declare function executeWithWorkerStrategy = readonly string[], Delimiter extends string = DEFAULT_DELIMITER, Quotation extends string = DEFAULT_QUOTATION>(input: string | CSVBinary | ReadableStream, options: ParseOptions | ParseBinaryOptions | undefined, session: WorkerSession | null, engineConfig: InternalEngineConfig): AsyncIterableIterator; /** * Register a custom worker strategy. * * @internal */ export declare function registerWorkerStrategy(strategy: WorkerStrategy): void;