import { RetryPolicy } from '@sha1n/about-time';
import { HandlerContext, StatefulPipelineEntity } from './types';
import { Pipeline } from './Pipeline';
declare function createPump<T extends StatefulPipelineEntity<S>, S, C extends HandlerContext>(pipeline: Pipeline<T, S, C>, retryPolicy?: RetryPolicy): (entity: T, ctx: C) => Promise<T>;
export default createPump;