Class PriceFeed

Private Optional activityMonitor

Private Optional client

Private Optional clientOpenPromise

Private connectionId

Private feed

Private Optional internalErrorCallback

Private internalPriceCallbacks

Private isConnecting

Private lastMessageTimestamp

Private localSubscriptions

Private options

Private remoteSubscriptions

Private Optional userErrorCallback

Private websocketUrl

• get websocketUrl(): string

• Returns string

Private handleMessage

• handleMessage(message): void

• Parameters

  • message: IMessageEvent

  Returns void

Private handlePrice

• handlePrice(pair, price, timestamp): void

• Parameters

  • pair: Pair

  • price: BigNumber

  • timestamp: number

  Returns void

Private handleReconnection

• handleReconnection(reconnectDelayMillis, e): Promise<void>

• Parameters

  • reconnectDelayMillis: number

  • e: ICloseEvent

  Returns Promise<void>

Private isNewSubscription

• isNewSubscription(subscription): boolean

• Parameters

  • subscription: SubscriptionPair

  Returns boolean

Private isSubscribedToPairLocal

• isSubscribedToPairLocal(pair): boolean

• Parameters

  • pair: Pair

  Returns boolean

Private publishPriceUpdate

• publishPriceUpdate(data): void

• Parameters

  • data: WebsocketPrice

  Returns void

Private removeOldSubscriptions

• removeOldSubscriptions(): void

• Returns void

Private setupConnection

• setupConnection(reconnectDelayMillis?): Promise<void>

• Parameters

  • reconnectDelayMillis: number = RECONNECT_DELAY

  Returns Promise<void>

Private startActivityMonitor

• startActivityMonitor(): Promise<void>

• Returns Promise<void>

Private subscribeRemote

• subscribeRemote(pairs): Promise<void>

• Subscribes to price updates from the remote server. Only returns when the prices have been received.

  Parameters

  • pairs: Pair[]

  Returns Promise<void>

Private unsubscribeRemote

• unsubscribeRemote(pairs): void

• Unsubscribes from price updates from the remote server.

  Parameters

  • pairs: Pair[]

  Returns void