Skip to content

Commit 0724548

Browse files
committed
feat: emit server warnings as events
1 parent 7c42549 commit 0724548

File tree

3 files changed

+3
-0
lines changed

3 files changed

+3
-0
lines changed

src/modules/StreamingClient.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -273,6 +273,7 @@ export class StreamingClient {
273273
case SignalMessageAction.WARNING:
274274
const message = signalMessage.payload as string;
275275
console.warn('Warning received from server: ' + message);
276+
this.publicEventEmitter.emit(AnamEvent.SERVER_WARNING, message);
276277
break;
277278
case SignalMessageAction.TALK_STREAM_INTERRUPTED:
278279
const chatMessage =

src/types/events/public/AnamEvent.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,4 +9,5 @@ export enum AnamEvent {
99
AUDIO_STREAM_STARTED = 'AUDIO_STREAM_STARTED',
1010
TALK_STREAM_INTERRUPTED = 'TALK_STREAM_INTERRUPTED',
1111
SESSION_READY = 'SESSION_READY',
12+
SERVER_WARNING = 'SERVER_WARNING',
1213
}

src/types/events/public/EventCallbacks.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,5 @@ export type EventCallbacks = {
1313
[AnamEvent.AUDIO_STREAM_STARTED]: (audioStream: MediaStream) => void;
1414
[AnamEvent.TALK_STREAM_INTERRUPTED]: (correlationId: string) => void;
1515
[AnamEvent.SESSION_READY]: (sessionId: string) => void;
16+
[AnamEvent.SERVER_WARNING]: (message: string) => void;
1617
};

0 commit comments

Comments
 (0)