import { AsyncSubscription } from './Subscription'; declare class AsyncEventEmitter { private readonly listeners; emit(value: T): void; subscribe(next: (value: T) => Promise, error?: (err: Error) => void, complete?: () => void): AsyncSubscription; subscribeOnce(next: (value: T) => Promise, error?: (err: Error) => void, complete?: () => void): void; unsubscribe(listener: (value: T) => Promise): void; } export { AsyncEventEmitter };