/**
 * @module @ddes/event-streaming
 */
/// <reference types="node" />
import { EventEmitter } from 'events';
import WebSocket from 'ws';
import { FilterSet } from './types';
export default class EventSubscriber extends EventEmitter {
    maxQueueSize: number;
    private socket?;
    private queue;
    isReady: Promise<boolean>;
    ready: boolean;
    constructor(params: {
        wsUrl: string;
        events: FilterSet[];
        maxQueueSize?: number;
    } & WebSocket.ClientOptions);
    close(): void | undefined;
    /**
     * @hidden
     */
    [Symbol.asyncIterator](): {
        next(): Promise<{
            value: object | undefined;
            done: boolean;
        }>;
        return(): Promise<{
            value: undefined;
            done: boolean;
        }>;
        throw(error: Error): Promise<never>;
    };
}