import { DEFAULT_DELIMITER, DEFAULT_QUOTATION } from '../../core/constants';
import { CSVRecord, ParseBinaryOptions, ParseOptions } from '../../core/types';
/**
 * Base interface for Worker requests
 * @internal
 */
interface BaseParseRequest {
    id: number;
    useWASM?: boolean;
    resultPort?: MessagePort;
}
/**
 * Parse string request
 * @internal
 */
export interface ParseStringRequest<Header extends ReadonlyArray<string> = readonly string[], Delimiter extends string = DEFAULT_DELIMITER, Quotation extends string = DEFAULT_QUOTATION> extends BaseParseRequest {
    type: "parseString";
    data: string;
    options?: ParseOptions<Header, Delimiter, Quotation>;
}
/**
 * Parse binary request
 * @internal
 */
export interface ParseBinaryRequest<Header extends ReadonlyArray<string> = readonly string[], Delimiter extends string = DEFAULT_DELIMITER, Quotation extends string = DEFAULT_QUOTATION> extends BaseParseRequest {
    type: "parseBinary";
    data: BufferSource;
    options?: ParseBinaryOptions<Header, Delimiter, Quotation>;
}
/**
 * Parse string stream request
 * @internal
 */
export interface ParseStringStreamRequest<Header extends ReadonlyArray<string> = readonly string[], Delimiter extends string = DEFAULT_DELIMITER, Quotation extends string = DEFAULT_QUOTATION> extends BaseParseRequest {
    type: "parseStream" | "parseStringStream";
    data?: ReadableStream<string>;
    stream?: ReadableStream<string>;
    options?: ParseOptions<Header, Delimiter, Quotation>;
}
/**
 * Parse binary stream request
 * @internal
 */
export interface ParseUint8ArrayStreamRequest<Header extends ReadonlyArray<string> = readonly string[], Delimiter extends string = DEFAULT_DELIMITER, Quotation extends string = DEFAULT_QUOTATION> extends BaseParseRequest {
    type: "parseBinaryStream";
    data?: ReadableStream<Uint8Array>;
    stream?: ReadableStream<Uint8Array>;
    options?: ParseBinaryOptions<Header, Delimiter, Quotation>;
}
/**
 * Message types for Worker communication.
 * @internal
 */
export type ParseRequest<Header extends ReadonlyArray<string> = readonly string[], Delimiter extends string = DEFAULT_DELIMITER, Quotation extends string = DEFAULT_QUOTATION> = ParseStringRequest<Header, Delimiter, Quotation> | ParseBinaryRequest<Header, Delimiter, Quotation> | ParseStringStreamRequest<Header, Delimiter, Quotation> | ParseUint8ArrayStreamRequest<Header, Delimiter, Quotation>;
export interface ParseResponse<Header extends ReadonlyArray<string> = readonly string[]> {
    id: number;
    result?: CSVRecord<Header>[] | ReadableStream<CSVRecord<Header>>;
    error?: string;
}
export interface ParseStreamResponse<Header extends ReadonlyArray<string> = readonly string[]> {
    id: number;
    type: "record" | "done" | "error";
    record?: CSVRecord<Header>;
    error?: string;
}
/**
 * Worker context interface (unified for Web Workers and Worker Threads)
 * @internal
 */
export interface WorkerContext<Header extends ReadonlyArray<string> = readonly string[]> {
    postMessage(message: ParseStreamResponse<Header>): void;
}
/**
 * Helper to stream records incrementally to avoid memory issues.
 * @internal
 */
export declare const streamRecordsToMain: <Header extends ReadonlyArray<string> = readonly string[]>(workerContext: WorkerContext<Header>, id: number, records: AsyncIterableIterator<CSVRecord<Header>> | Iterable<CSVRecord<Header>>) => Promise<void>;
/**
 * Helper to stream records to a MessagePort (for TransferableStream strategy).
 * @internal
 */
export declare const streamRecordsToPort: <Header extends ReadonlyArray<string> = readonly string[]>(port: MessagePort, records: AsyncIterableIterator<CSVRecord<Header>> | Iterable<CSVRecord<Header>>) => Promise<void>;
/**
 * Worker message handler for CSV parsing.
 * Handles different parsing strategies (regular, WASM, streaming).
 *
 * @internal
 */
export declare const createMessageHandler: (workerContext: WorkerContext) => (request: ParseRequest) => Promise<void>;
export {};