import type { IStream } from '../types.js';
export declare const join: <A>(stream: IStream<IStream<A>>) => IStream<A>;
export declare const joinMap: IJoinMapCurry;
export declare const joinConcurrentlyMap: IMergeConcurrentlyMapCurry;
export declare const joinMapConcurrently: IMergeMapConcurrentlyCurry;
export interface IJoinMapCurry {
    <A, B>(f: (a: A) => IStream<B>, source: IStream<A>): IStream<B>;
    <A, B>(f: (a: A) => IStream<B>): (source: IStream<A>) => IStream<B>;
}
export interface IMergeConcurrentlyMapCurry {
    <A>(concurrency: number, stream: IStream<IStream<A>>): IStream<A>;
    <A>(concurrency: number): (stream: IStream<IStream<A>>) => IStream<A>;
}
export interface IMergeMapConcurrentlyCurry {
    <A, B>(f: (a: A) => IStream<B>, concurrency: number, stream: IStream<A>): IStream<B>;
    <A, B>(f: (a: A) => IStream<B>, concurrency: number): (stream: IStream<A>) => IStream<B>;
    <A, B>(f: (a: A) => IStream<B>): (concurrency: number) => (stream: IStream<A>) => IStream<B>;
}