feat(websocket-client): sendMessage is now public; support timeout param

This commit is contained in:
Martin Varmuza
2025-03-19 16:07:35 +01:00
committed by martin
parent 931c8d2985
commit b0740c419e
2 changed files with 3 additions and 3 deletions

View File

@@ -37,7 +37,7 @@ export abstract class BaseWebsocket<T extends Record<string, any>> extends Webso
});
}
protected sendMessage(message: WebsocketRequest) {
sendMessage(message: WebsocketRequest) {
return super.sendMessage(message).catch(error => {
throw new CustomError(error.message);
});

View File

@@ -94,10 +94,10 @@ export class WebsocketClient<Events extends Record<string, any>> extends TypedEm
this.onClose();
}
protected sendMessage(message: WebsocketRequest) {
sendMessage(message: WebsocketRequest, { timeout }: { timeout?: number } = {}) {
const { ws } = this;
if (!ws || !this.isConnected()) throw new Error('websocket_not_initialized');
const { promiseId, promise } = this.messages.create();
const { promiseId, promise } = this.messages.create(timeout);
const req = { id: promiseId.toString(), ...message };