import { AsyncActivity, type AsyncActivityResult, type Binary, type AnyWorkflow, WorkflowBatchCollectionRef, workflowBatchSchema } from '@t4h.framework/core'; import { type ByteTrim, type FileSplitDelimiter } from '../helpers/split-records.js'; type FileSplitWhereOperators = { $eq?: string; $ne?: string; $lt?: string; $lte?: string; $gt?: string; $gte?: string; $in?: string[]; $nin?: string[]; $regex?: string; $options?: string; $not?: FileSplitWhere; }; export type FileSplitWhere = string | (FileSplitWhereOperators & { $and?: FileSplitWhere[]; $or?: FileSplitWhere[]; $nor?: FileSplitWhere[]; }); export type FileSplitOptions = { delimiter: FileSplitDelimiter; every?: number; where?: FileSplitWhere; trim?: ByteTrim; skipEmpty?: boolean; encoding?: BufferEncoding; timeoutInMs?: number; }; export type FileSplitActivityInput = { binary: Binary; workflow: string; options: FileSplitOptions; }; export type FileSplitBatch = { batch: string; count: number; }; export declare class FileSplitActivity extends AsyncActivity { private readonly claims; toInput(binary: Binary, workflow: AnyWorkflow, options: FileSplitOptions): FileSplitActivityInput; bootstrap({ binary, workflow, options, }: FileSplitActivityInput): Promise>; private slices; private filter; advance(payload: FileSplitBatch): import("@t4h.framework/core").AsyncActivityResultFulfilled; toOutput(output: FileSplitBatch): WorkflowBatchCollectionRef; } export declare function split(binary: Binary, workflow: AnyWorkflow, options: FileSplitOptions): Promise; export declare namespace Split { const line: (value?: string) => FileSplitDelimiter; const char: (value: string, keep?: FileSplitDelimiter["keep"]) => FileSplitDelimiter; } export {}; //# sourceMappingURL=FileSplitActivity.d.ts.map