import { IObservable } from '../internal/Observable';
export declare type Project<T, S> = (t: T) => IObservable<S>;
export declare type mergeMapFunctionWithConcurrency = {
    <T, S>(concurrency: IObservable<number>, project: Project<T, S>, source: IObservable<T>): IObservable<S>;
    <T, S>(concurrency: IObservable<number>): {
        (project: Project<T, S>, source: IObservable<T>): IObservable<S>;
    };
    <T, S>(concurrency: IObservable<number>): {
        (project: Project<T, S>): {
            (source: IObservable<T>): IObservable<S>;
        };
    };
};
export declare type mergeMapFunction = {
    <T, S>(project: Project<T, S>, source: IObservable<T>): IObservable<S>;
    <T, S>(project: Project<T, S>, source: IObservable<T>): IObservable<S>;
    <T, S>(project: Project<T, S>): {
        (source: IObservable<T>): IObservable<S>;
    };
};
export declare type joinFunction = <T>(source: IObservable<IObservable<T>>) => IObservable<T>;
export declare const mergeMap: mergeMapFunctionWithConcurrency;
export declare const flatMap: mergeMapFunction;
export declare const concatMap: mergeMapFunction;
export declare const join: joinFunction;