import { Subject, Subscription } from 'rxjs';
export declare class EventEmitter<T = any> extends Subject<T> {
    protected __isAsync: boolean;
    constructor(isAsync?: boolean);
    emit(value?: any): void;
    subscribe(generatorOrNext?: any, error?: any, complete?: any): Subscription;
}
export declare class PreserveNextEventEmitter<T> extends EventEmitter<T> {
    private _schedulerFns;
    private _isAsync;
    get schedulerFns(): Set<any> | undefined;
    forceCallback(value: T, once?: boolean): void;
    cleanCallbackFn(): void;
    subscribe(generatorOrNext?: any, error?: any, complete?: any): any;
}