Options
All
  • Public
  • Public/Protected
  • All
Menu

Hierarchy

  • WebsocketClient

Implements

  • RpcStreamingClient

Index

Constructors

  • new WebsocketClient(baseUrl: string, onError?: ((err: any) => void)): WebsocketClient

Methods

  • connected(): Promise<void>
  • Resolves as soon as websocket is connected. execute() queues requests automatically, so this should be required for testing purposes only.

    Returns Promise<void>

  • disconnect(): void
  • execute(request: JsonRpcRequest): Promise<JsonRpcSuccessResponse>
  • listen(request: JsonRpcRequest): Stream<SubscriptionEvent>
  • responseForRequestId(id: JsonRpcId): Promise<JsonRpcResponse>

Generated using TypeDoc