import { StreamDebounce } from './transformations/debounce';
import { StreamFilter } from './transformations/filter';
import { StreamMapping } from './transformations/mapping';
import { StreamSignal } from './transformations/signal';
import { DebounceParameters, SignalParameters, State, StateChangeListener, StateChangeTransformation } from './types';
export type Subscriber<T> = StateChangeListener<T> | Stream<T>;
export declare class Stream<T> {
    private _onNext;
    private _previousState?;
    private _state?;
    isInitialized(): boolean;
    get state(): State<T> | undefined;
    get value(): T | undefined;
    toJSON(): T | undefined;
    publish(value: T | State<T> | undefined): void;
    then(subscriber: Subscriber<T>): Stream<T>;
    subscribe(subscriber: Subscriber<T>): Stream<T>;
    default(value: T): Stream<T>;
    filter(): StreamFilter<T>;
    map(): StreamMapping<T>;
    debounce(params?: DebounceParameters): StreamDebounce<T>;
    signal(params?: SignalParameters): StreamSignal<T>;
    extract<U extends keyof T>(key: U): Stream<Required<T>[U]>;
    join<StreamMap extends object, U>(map: {
        [key in keyof StreamMap]: Stream<StreamMap[key]>;
    }, transform: StateChangeTransformation<StreamMap & {
        this: Stream<T>;
    }, U>): Stream<U>;
    static join<T extends object>(map: {
        [key in keyof T]: Stream<T[key]>;
    }): Stream<T>;
    static of<T>(...streams: Stream<T>[]): Stream<T[]>;
    static anyReady<T>(...streams: Stream<T>[]): Stream<T[]>;
    static anyOf(...streams: Stream<boolean>[]): Stream<boolean>;
    static allOf(...streams: Stream<boolean>[]): Stream<boolean>;
    static just<T>(data: T): Stream<T>;
    createStream<T>(): Stream<T>;
    protected isCallback<T>(source: any): source is T;
}