Method addObserver

packages/server/src/utils/SSEStreamer.ts:33–40

(sourceChatId: string, observerId: string)

    }

    addObserver(sourceChatId: string, observerId: string) {
        let set = this.observers.get(sourceChatId)
        if (!set) {
            set = new Set()
            this.observers.set(sourceChatId, set)
        }
        set.add(observerId)
    }

    removeObserver(sourceChatId: string, observerId: string) {
        const set = this.observers.get(sourceChatId)