import { Subscription } from "./Subscription";
import { SubjectKind } from "./SubjectKind";
import { class_Dfr, class_EventEmitter } from 'atma-utils';
export declare class SubjectStream<T = any> {
    value: T;
    protected _error: Error | any;
    protected _inner: SubjectStream;
    protected _innerSub: Subscription;
    protected _pipe: SubjectStream;
    protected _pipeSub: Subscription;
    protected _mapper: (value: any) => T;
    protected _events: class_EventEmitter;
    protected _cbs: [
        ((x: T) => void),
        ((err: Error | any) => void),
        {
            once?: boolean;
        }
    ][];
    onConnected: class_Dfr<any>;
    kind: SubjectKind;
    canceled: boolean;
    constructor();
    next(x: T): void;
    onValue(val: any): void;
    error(err: Error | any): void;
    connected(error?: any): void;
    current(): T;
    isBusy(): boolean;
    fromStream(stream: SubjectStream, inner?: SubjectStream): void;
    subscribe(cb: (x: T) => void, onError?: (x: Error | any) => void, once?: any): Subscription;
    unsubscribe(cb?: Function): void;
    on(type: 'data' | 'connected' | 'error', cb: any): void;
    private onInnerChanged;
    private call;
}