forinvest-cli
    Preparing search index...

    Interface IPubsubConnectorService

    interface IPubsubConnectorService {
        addSubscriptions(
            subId: number,
            symbols: string[],
            fields: string[],
            callback?: (data: any) => any,
        ): void;
        callback(data: PubsubData): void;
        changeUser(
            username?: string,
            password?: string,
            token?: string,
            resource?: string,
        ): Promise<void>;
        checkSubscriptionHasSnapshot(symbols: string[], fields: string[]): void;
        connect(): Promise<WebSocket>;
        disconnect(): Promise<void>;
        feedSubscriptions(data: PubsubData): void;
        getFieldSnapShotValue(definitionId: string, fieldShortCode: string): any;
        getLicenses(): PubsubLicense[];
        getSocket(): WebSocket;
        getSubscriptions(): any;
        getSubscriptionsById(id: string): any;
        isSocketReady(): boolean;
        login(username: string, password: string, resource: string): void;
        messageEvent(data: PubsubData): void;
        resetReconnectCount(): void;
        reSubscribe(): void;
        scheduleHeartbeat(): void;
        send(message: string): void;
        setGlobalCallback(callback: Function): void;
        setOptions(options: any): void;
        subscribe(
            symbols: string[],
            fields: string[],
            callback?: (data: PubsubData) => void,
        ): number;
        unSubscribe(id: number): void;
        unSubscribeAll(): void;
    }
    Index

    Methods

    addSubscriptions callback changeUser checkSubscriptionHasSnapshot connect disconnect feedSubscriptions getFieldSnapShotValue getLicenses getSocket getSubscriptions getSubscriptionsById isSocketReady login messageEvent resetReconnectCount reSubscribe scheduleHeartbeat send setGlobalCallback setOptions subscribe unSubscribe unSubscribeAll

    Methods

    • Parameters

      • subId: number

        : subscription id

      • symbols: string[]

        : symbols list

      • fields: string[]

        : fields list

      • Optionalcallback: (data: any) => any

        : callback method

      Returns void

    • Parameters

      Returns void

    • Parameters

      • Optionalusername: string
      • Optionalpassword: string
      • Optionaltoken: string
      • Optionalresource: string

      Returns Promise<void>

    • Parameters

      • symbols: string[]

        symbols list

      • fields: string[]

        fields list

      Returns void

    • Returns Promise<WebSocket>

    • Returns Promise<void>

    • Parameters

      Returns void

    • Parameters

      • definitionId: string

        definition id

      • fieldShortCode: string

        fields shortcode

      Returns any

      field value

    • Returns WebSocket

    • Returns any

    • Parameters

      • id: string

        id

      Returns any

    • Returns boolean

    • Parameters

      • username: string

        username

      • password: string

        password

      • resource: string

        resource

      Returns void

    • Parameters

      Returns void

    • Returns void

    • Returns void

    • Returns void

    • Parameters

      • message: string

        message

      Returns void

    • Parameters

      • callback: Function

      Returns void

    • Parameters

      • options: any

        : options

      Returns void

    • Parameters

      • symbols: string[]

        symbols list

      • fields: string[]

        fields list

      • Optionalcallback: (data: PubsubData) => void

        callback method

      Returns number

      subscription id

    • Parameters

      • id: number

        subscription id

      Returns void

    • Returns void

    Settings

    Member Visibility

    On This Page

    Methods