import type { IStream } from '../types.js';
/**
 * Switch to the latest inner stream, disposing the previous one
 *
 * stream of streams: -A--B--C|
 *           A:       -a-b-c|
 *           B:          -d-e-f|
 *           C:             -g-h-i-j|
 * switchLatest:      -a-b-d-e-g-h-i-j|
 *
 * The output stream remains active as long as:
 * - The source stream (stream of streams) is still active, OR
 * - The latest inner stream is still active
 *
 * It only ends when both have ended.
 */
export declare const switchLatest: <T>(source: IStream<IStream<T>>) => IStream<T>;
/**
 * Map each value to a stream and switch to the latest one.
 *
 * stream:             -a----b----c->
 * switchMap(x => x$): -aa---bbb--ccc->
 *   where a$ = -a-a-|
 *         b$ = -b-b-b-|
 *         c$ = -c-c-c->
 */
export declare const switchMap: ISwitchMapCurry;
export type IStreamOrPromise<T> = IStream<T> | Promise<T>;
export interface ISwitchMapCurry {
    <T, R>(cb: (t: T) => IStreamOrPromise<R>, s: IStream<T>): IStream<R>;
    <T, R>(cb: (t: T) => IStreamOrPromise<R>): (s: IStream<T>) => IStream<R>;
}
export declare const switchPromises: <T>(source: IStream<Promise<T>>) => IStream<T>;