diff options
author | Nate Sesti <sestinj@gmail.com> | 2023-07-16 16:25:02 -0700 |
---|---|---|
committer | Nate Sesti <sestinj@gmail.com> | 2023-07-16 16:25:02 -0700 |
commit | 4c3a25a1c8938f8132233e021c74d98eb19d7ddd (patch) | |
tree | 8460e5703f224e7ef5c2c7eca6b470f338b93e1e /extension/src/util/messenger.ts | |
parent | 3ded151331933c9a1352cc46c3cc67c5733d1c86 (diff) | |
parent | a4a815628f702af806603015ec6805edd151328b (diff) | |
download | sncontinue-4c3a25a1c8938f8132233e021c74d98eb19d7ddd.tar.gz sncontinue-4c3a25a1c8938f8132233e021c74d98eb19d7ddd.tar.bz2 sncontinue-4c3a25a1c8938f8132233e021c74d98eb19d7ddd.zip |
Merge branch 'main' into ggml-server
Diffstat (limited to 'extension/src/util/messenger.ts')
-rw-r--r-- | extension/src/util/messenger.ts | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/extension/src/util/messenger.ts b/extension/src/util/messenger.ts index b1df161b..3044898e 100644 --- a/extension/src/util/messenger.ts +++ b/extension/src/util/messenger.ts @@ -16,6 +16,8 @@ export abstract class Messenger { abstract onClose(callback: () => void): void; + abstract onError(callback: () => void): void; + abstract sendAndReceive(messageType: string, data: any): Promise<any>; } @@ -26,6 +28,7 @@ export class WebsocketMessenger extends Messenger { } = {}; private onOpenListeners: (() => void)[] = []; private onCloseListeners: (() => void)[] = []; + private onErrorListeners: (() => void)[] = []; private serverUrl: string; _newWebsocket(): WebSocket { @@ -43,6 +46,9 @@ export class WebsocketMessenger extends Messenger { for (const listener of this.onCloseListeners) { this.onClose(listener); } + for (const listener of this.onErrorListeners) { + this.onError(listener); + } for (const messageType in this.onMessageListeners) { for (const listener of this.onMessageListeners[messageType]) { this.onMessageType(messageType, listener); @@ -151,4 +157,8 @@ export class WebsocketMessenger extends Messenger { onClose(callback: () => void): void { this.websocket.addEventListener("close", callback); } + + onError(callback: () => void): void { + this.websocket.addEventListener("error", callback); + } } |