Skip to content

Class: WebsocketClient ​

Extends ​

Constructors ​

Constructor ​

ts
new WebsocketClient(options?: WebsocketClientOptions, logger?: object): WebsocketClient;

Parameters ​

ParameterTypeDefault value
options?WebsocketClientOptions{}
logger?{ error: (...params: LogParams) => void; info: (...params: LogParams) => void; trace: (..._params: LogParams) => void; }DefaultLogger
logger.error?(...params: LogParams) => void...
logger.info?(...params: LogParams) => void...
logger.trace?(..._params: LogParams) => void...

Returns ​

WebsocketClient

Overrides ​

BaseWebsocketClient<WsKey, WebsocketSubscription>.constructor

Methods ​

addListener() ​

ts
addListener<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, listener: (...args: WebsocketClientEventMap<WsKey>[K]) => void): this;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
listener(...args: WebsocketClientEventMap<WsKey>[K]) => void

Returns ​

this

Inherited from ​

BaseWebsocketClient.addListener


close() ​

ts
close(wsKey?: WsKey): void;

Reject pending work immediately; emit 'close' when the socket confirms closure.

Parameters ​

ParameterType
wsKey?WsKey

Returns ​

void


closeAll() ​

ts
closeAll(): void;

Returns ​

void

See ​

Shut down cleanly

Inherited from ​

BaseWebsocketClient.closeAll


connect() ​

ts
connect(wsKey?: WsKey): Promise<void>;

Parameters ​

ParameterTypeDefault value
wsKey?WsKey'public'

Returns ​

Promise<void>


connectAll() ​

ts
connectAll(): Promise<void>;

Connect all cached connection groups, or the public connection if none exist.

Returns ​

Promise<void>


emit() ​

ts
emit<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, ...args: WebsocketClientEventMap<WsKey>[K]): boolean;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
...argsWebsocketClientEventMap<WsKey>[K]

Returns ​

boolean

Inherited from ​

BaseWebsocketClient.emit


eventNames() ​

ts
eventNames(): (keyof WebsocketClientEventMap<WsKey>)[];

Returns ​

(keyof WebsocketClientEventMap<WsKey>)[]

Inherited from ​

BaseWebsocketClient.eventNames


getMaxListeners() ​

ts
getMaxListeners(): number;

Returns ​

number

Inherited from ​

BaseWebsocketClient.getMaxListeners


isConnected() ​

ts
isConnected(wsKey?: WsKey): boolean;

Parameters ​

ParameterTypeDefault value
wsKey?WsKey'public'

Returns ​

boolean


listenerCount() ​

ts
listenerCount<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, listener?: (...args: WebsocketClientEventMap<WsKey>[K]) => void): number;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
listener?(...args: WebsocketClientEventMap<WsKey>[K]) => void

Returns ​

number

Inherited from ​

BaseWebsocketClient.listenerCount


listeners() ​

ts
listeners<K extends keyof WebsocketClientEventMap<WsKey>>(event: K): ((...args: WebsocketClientEventMap<WsKey>[K]) => void)[];

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK

Returns ​

((...args: WebsocketClientEventMap<WsKey>[K]) => void)[]

Inherited from ​

BaseWebsocketClient.listeners


nameToCoin() ​

ts
nameToCoin(name: string): Promise<string>;

Parameters ​

ParameterType
namestring

Returns ​

Promise<string>


off() ​

ts
off<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, listener: (...args: WebsocketClientEventMap<WsKey>[K]) => void): this;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
listener(...args: WebsocketClientEventMap<WsKey>[K]) => void

Returns ​

this

Inherited from ​

BaseWebsocketClient.off


on() ​

ts
on<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, listener: (...args: WebsocketClientEventMap<WsKey>[K]) => void): this;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
listener(...args: WebsocketClientEventMap<WsKey>[K]) => void

Returns ​

this

Inherited from ​

BaseWebsocketClient.on


once() ​

ts
once<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, listener: (...args: WebsocketClientEventMap<WsKey>[K]) => void): this;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
listener(...args: WebsocketClientEventMap<WsKey>[K]) => void

Returns ​

this

Inherited from ​

BaseWebsocketClient.once


prependListener() ​

ts
prependListener<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, listener: (...args: WebsocketClientEventMap<WsKey>[K]) => void): this;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
listener(...args: WebsocketClientEventMap<WsKey>[K]) => void

Returns ​

this

Inherited from ​

BaseWebsocketClient.prependListener


prependOnceListener() ​

ts
prependOnceListener<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, listener: (...args: WebsocketClientEventMap<WsKey>[K]) => void): this;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
listener(...args: WebsocketClientEventMap<WsKey>[K]) => void

Returns ​

this

Inherited from ​

BaseWebsocketClient.prependOnceListener


rawListeners() ​

ts
rawListeners<K extends keyof WebsocketClientEventMap<WsKey>>(event: K): ((...args: WebsocketClientEventMap<WsKey>[K]) => void)[];

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK

Returns ​

((...args: WebsocketClientEventMap<WsKey>[K]) => void)[]

Inherited from ​

BaseWebsocketClient.rawListeners


refreshAssetMetadata() ​

ts
refreshAssetMetadata(): Promise<void>;

Returns ​

Promise<void>


removeAllListeners() ​

ts
removeAllListeners(event?: keyof WebsocketClientEventMap<WsKey>): this;

Parameters ​

ParameterType
event?keyof WebsocketClientEventMap<WsKey>

Returns ​

this

Inherited from ​

BaseWebsocketClient.removeAllListeners


removeListener() ​

ts
removeListener<K extends keyof WebsocketClientEventMap<WsKey>>(event: K, listener: (...args: WebsocketClientEventMap<WsKey>[K]) => void): this;

Type Parameters ​

Type Parameter
K extends keyof WebsocketClientEventMap<WsKey>

Parameters ​

ParameterType
eventK
listener(...args: WebsocketClientEventMap<WsKey>[K]) => void

Returns ​

this

Inherited from ​

BaseWebsocketClient.removeListener


resolveAsset() ​

ts
resolveAsset(identifier: string | number): Promise<ResolvedAsset>;

Parameters ​

ParameterType
identifierstring | number

Returns ​

Promise<ResolvedAsset>


sendWSAPIRequest() ​

ts
sendWSAPIRequest<T>(
   endpoint: "info" | "action", 
   body: unknown, 
   options?: RequestOptions
): Promise<T>;

Type Parameters ​

Type Parameter
T

Parameters ​

ParameterType
endpoint"info" | "action"
bodyunknown
options?RequestOptions

Returns ​

Promise<T>


setMaxListeners() ​

ts
setMaxListeners(count: number): this;

Parameters ​

ParameterType
countnumber

Returns ​

this

Inherited from ​

BaseWebsocketClient.setMaxListeners


subscribe() ​

ts
subscribe(subscriptions: 
  | WebsocketSubscription
| readonly WebsocketSubscription[]): Promise<void>;

Subscribe to one or more wire topics. Listen for data with on('message'). Topics are cached before connecting and restored automatically after reconnect. The promise confirms local sending; server acknowledgements emit 'response'. Resolve display aliases explicitly with nameToCoin() when needed.

Parameters ​

ParameterType
subscriptions| WebsocketSubscription | readonly WebsocketSubscription[]

Returns ​

Promise<void>

See ​

Subscribe to market data


unsubscribe() ​

ts
unsubscribe(subscriptions: 
  | WebsocketSubscription
| readonly WebsocketSubscription[]): Promise<void>;

Remove cached topics independently of event listeners, including while disconnected.

Parameters ​

ParameterType
subscriptions| WebsocketSubscription | readonly WebsocketSubscription[]

Returns ​

Promise<void>

Built by Siebly. Open source SDKs for exchange APIs.