Options
All
  • Public
  • Public/Protected
  • All
Menu

External module "binance/ws_clients/public_ws_handler"

Index

Variables

Functions

Variables

Const binancePublicWS

binancePublicWS: WebSocketSubject<unknown> = webSocket({url: `${baseWsURL}/stream`,WebSocketCtor: WebSocket,openObserver: onBinancePublicWSOpened,closeObserver: onBinancePublicWSClosed})

Const onBinancePublicWSClosed

onBinancePublicWSClosed: Subject<unknown> = new Subject()

Const onBinancePublicWSOpened

onBinancePublicWSOpened: Subject<unknown> = new Subject()

Functions

Const getBinancePublicObservableFromWS

  • getBinancePublicObservableFromWS(streamNames: string[], filterFn?: (data: unknown) => boolean, unsubscriptionData?: any): Observable<any>

  • Parameters

    • streamNames: string[]
    • Default value filterFn: (data: unknown) => boolean = ({ stream = '' }): boolean => streamNames.includes(stream)
        • (data: unknown): boolean

        • Parameters

          • data: unknown

          Returns boolean

    • Optional unsubscriptionData: any

    Returns Observable<any>

Generated using TypeDoc