import { IDispatcher, PipelineExecutionResult, IPipeline } from '@src/corebus/interfaces';
export declare class PipelineThrowError<T> implements IPipeline<T> {
    constructor(dispatcher: IDispatcher<T>);
    executeStopOnError(events: T[]): PipelineExecutionResult<T>;
    executeContinueOnError(events: T[]): PipelineExecutionResult<T>;
}
export declare function pipelineThrowErrorFactory<T>(scheduler: IDispatcher<T>): IPipeline<T>;