import { ApiEndpoint, ApiEndpoints, DeepPartial, HttpResponse, HttpClient, RDPResponse, OMMResponse, socketCreator, StreamConnection, StreamLoginParams, Session, SessionRequestParams } from '@refinitiv-data/types'; import { AbstractStateManager } from '../../state/state-manager'; export declare abstract class AbstractSession extends AbstractStateManager implements Session { protected readonly httpClient: HttpClient; protected get invalidStateMessage(): string; protected abstract get cookieJarSupport(): boolean; isEndpointSupported: boolean; protected log: import("loglevel").Logger; protected sessionEventsEmitter: Session; protected streamConnections: Map>; private getStreamConnectionLimit; private cookieJar; constructor(httpClient?: HttpClient); sendRequest(requestParams: SessionRequestParams): Promise>; getOMMStreamConnection(api?: string, validateState?: boolean): Promise>; getRDPStreamConnection(api?: string, validateState?: boolean): Promise>; /** * This method is related to the endpoints overriding in the configuration file. * 'sessions' section in the config file contains different types of sessions, * and each session might have a specific block to override common endpoint(s) * api/url/path for this particular session. * Overridden endpoint has a higher priority then common one. * * An empty object is returned if there are no overridden endpoints */ abstract getOverriddenEndpoints(): DeepPartial; /** * The same as getOverriddenEndpoints but for particular endpoint * @param name - Optional. Name of endpoint we would like to get. */ getOverriddenEndpoint(group: keyof ApiEndpoints, name: string): DeepPartial | undefined; protected abstract initialize(): Promise; protected abstract request(requestParams: SessionRequestParams): Promise>; protected abstract getSocketCreators(api: string, protocol: string): Promise; protected abstract getStreamLoginParams(): StreamLoginParams; protected cleanUp(): Promise; private getStreamingTypes; private checkAndValidateState; private createStreamConnection; private getStreamConnection; private mapError; private mapReconnectError; private addCookies; private getCookies; private saveCookies; }