import { Err, Result } from 'neverthrow';
type Processor<TInput, TEvent, TResult> = (params: {
    input: TInput;
    emit: (event: TEvent) => Promise<Result<void, Error>>;
    signal?: AbortSignal;
}) => TResult | Promise<TResult>;
export declare class ProcessorHandlerError extends Error {
    cause: unknown;
    constructor(cause: unknown);
}
export declare function createProcessor<TInput, TEvent>(): {
    handle: <TResult extends Result<unknown, Error>>(fn: Processor<TInput, TEvent, TResult>) => (input: TInput, options?: {
        signal?: AbortSignal;
    }) => {
        forEach: (handler?: (event: TEvent, options: {
            signal?: AbortSignal;
        }) => unknown | Promise<unknown>) => Promise<TResult | Err<unknown, Error>>;
        then: <T>(onfulfilled: (value: TResult | Err<unknown, Error>) => T | Promise<T>) => Promise<void>;
    };
};
export {};