import { TemplatedApp, WebSocket } from 'uWebSockets.js';
import { SubRequest } from './types';
export declare class DataStreams {
    private readonly _app;
    private readonly _options;
    private _publishersInitialized;
    constructor(_app: TemplatedApp, _options: {
        nodeEndpoint: string;
    });
    handleSubscriptionRequest(ws: WebSocket, message: ArrayBuffer): void;
    setUpPublishers(): Promise<void>;
    private _setUpPublisherForMarket;
    private _onBidsAccountChanged;
    private _publish;
    private _reduceToL2;
    _validateRequestPayload(payload: SubRequest): {
        readonly isValid: false;
        readonly error: string;
    } | {
        readonly isValid: true;
        readonly error: undefined;
    };
}
//# sourceMappingURL=data-streams.d.ts.map