Options
All
  • Public
  • Public/Protected
  • All
Menu

External module "kraken/ws_clients/public_ws_handler"

Index

Variables

Functions

Variables

Const krakenPublicWS

krakenPublicWS: WebSocketSubject<unknown> = webSocket({protocol: 'v1',url: 'wss://ws.kraken.com',WebSocketCtor: WebSocket,openObserver: onKrakenPublicWSOpened,closeObserver: onKrakenPublicWSClosed})

Const onKrakenPublicWSClosed

onKrakenPublicWSClosed: Subject<unknown> = new Subject()

Const onKrakenPublicWSHeartbeat$

onKrakenPublicWSHeartbeat$: Observable<Object> = krakenPublicWS.pipe(filter(({ event = null }) => event && event === 'heartbeat'))

Const onKrakenPublicWSOpened

onKrakenPublicWSOpened: Subject<unknown> = new Subject()

Functions

Const getKrakenPublicObservableFromWS

  • getKrakenPublicObservableFromWS(subscriptionData: any, filterFn: (data: unknown) => boolean, unsubscriptionData?: any): Observable<any>

  • Parameters

    • subscriptionData: any
    • filterFn: (data: unknown) => boolean
        • (data: unknown): boolean

        • Parameters

          • data: unknown

          Returns boolean

    • Optional unsubscriptionData: any

    Returns Observable<any>

Generated using TypeDoc