import { IPipeContext } from './IPipeContext';
import { IPipeActivity } from './IPipeActivity';
import { Activity, IActivity } from '@taskfr/core';
import { ITransform } from './ITransform';
import { TransformType } from './pipeTypes';
import { IPipeConfigure } from './IPipeConfigure';
/**
 * Pipe activity.
 *
 * @export
 * @class BaseTask
 * @implements {ITask}
 */
export declare class PipeActivity extends Activity<ITransform> implements IPipeActivity {
    /**
     * context.
     *
     * @type {IPipeContext}
     * @memberof BaseTask
     */
    context: IPipeContext;
    /**
     * pipes.
     *
     * @type {TransformType[]}
     * @memberof PipeComponent
     */
    pipes: TransformType[];
    /**
     * stream merger.
     *
     * @type {TransformMerger}
     * @memberof PipeComponent
     */
    merger: TransformType;
    /**
     * pipe config.
     *
     * @type {IPipeConfigure}
     * @memberof PipeActivity
     */
    config: IPipeConfigure;
    /**
     * run task.
     *
     * @param {*} [data]
     * @param {IActivity} [execute]
     * @returns {Promise<T>}
     * @memberof Activity
     */
    run(data?: any, execute?: IActivity): Promise<ITransform>;
    /**
     * execute pipes.
     *
     * @protected
     * @param {ITransform} stream
     * @returns {Promise<ITransform>}
     * @memberof PipeActivity
     */
    protected execute(stream: ITransform): Promise<ITransform>;
    /**
     * begin pipe.
     *
     * @protected
     * @param {ITransform} stream
     * @param {IActivity} [execute]
     * @returns {Promise<ITransform>}
     * @memberof PipeActivity
     */
    protected beforePipe(stream: ITransform, execute?: IActivity): Promise<ITransform>;
    /**
     * end pipe.
     *
     * @protected
     * @param {ITransform} stream
     * @param {IActivity} [execute]
     * @returns {Promise<ITransform>}
     * @memberof PipeActivity
     */
    protected afterPipe(stream: ITransform, execute?: IActivity): Promise<ITransform>;
    /**
     * pipe transform.
     *
     * @protected
     * @param {ITransform} stream
     * @param {...TransformType[]} pipes
     * @returns {Promise<ITransform>}
     * @memberof PipeActivity
     */
    protected pipe(stream: ITransform, ...pipes: TransformType[]): Promise<ITransform>;
    /**
     * merge transforms
     *
     * @protected
     * @param {...ITransform[]} data
     * @returns {Promise<ITransform>}
     * @memberof PipeComponent
     */
    protected merge(...data: ITransform[]): Promise<ITransform>;
    /**
     * execute pipe.
     *
     * @protected
     * @param {ITransform} stream
     * @param {TransformType} transform
     * @returns {Promise<ITransform>}
     * @memberof PipeComponent
     */
    protected executePipe(stream: ITransform, transform: TransformType, waitend?: boolean): Promise<ITransform>;
    static classAnnations: any;
}