import { ObservableLike } from '@dws/muster-observable';
import { Stream, StreamSubscription, StreamUpdateCallback, Subject } from '../types/stream';
export declare function never(): Stream<never>;
export declare function just<T>(value: T): Stream<T>;
export declare function defer<T>(factory: () => Stream<T>): Stream<T>;
export declare function skipRepeatedValues<T>(equality: (value: T, previousValue: T) => boolean, stream: Stream<T>): Stream<T>;
export declare function filter<T>(predicate: (value: T) => boolean, stream: Stream<T>): Stream<T>;
export declare function map<T, V>(project: (value: T) => V, stream: Stream<T>): Stream<V>;
export declare function tap<T>(fn: (value: T) => void, stream: Stream<T>): Stream<T>;
export declare function merge<T>(...streams: Array<Stream<T>>): Stream<T>;
export declare function flatten<T>(stream: Stream<Stream<T>>): Stream<T>;
export declare function combineLatest<T, V>(combine: (values: Array<T>) => V, streams: Array<Stream<T>>): Stream<V>;
export declare function sample<T>(sampleStream: Stream<any>, sourceStream: Stream<T>): Stream<T>;
export declare function takeFirst<T>(stream: Stream<T>): Stream<T>;
export declare function takeUntilPredicate<T>(predicate: (value: T) => boolean, stream: Stream<T>): Stream<T>;
export declare function switchMap<V, T>(project: (value: V) => Stream<T>, stream: Stream<V>): Stream<T>;
export declare function mapRecursive<T>(project: (value: T) => T | Stream<T>, stream: Stream<T>): Stream<T>;
export declare function addStreamListeners<T>(stream: Stream<T>, options: {
    subscribe?: () => void;
    unsubscribe?: () => void;
    invalidate?: (invalidate: () => void) => void;
}): Stream<T>;
export declare function subject<T>(): Subject<T>;
export declare function behaviorSubject<T>(initialValue: T): Subject<T>;
export declare function share<T>(stream: Stream<T>): Stream<T>;
export declare function fromEmitter<T>(emitter: {
    emit(event: T): void;
    listen(callback: (event: T) => void): () => void;
}): Stream<T>;
export declare function toObservable<T>(stream: Stream<T>): ObservableLike<T>;
export declare function createStream<T>(factory: (callback: StreamUpdateCallback<T>) => StreamSubscription): Stream<T>;
export declare function createSubscription(actions: {
    unsubscribe(): void;
    invalidate(): void;
}): StreamSubscription;