Function waveEventSubscribeSingle

frontend/app/store/wps.ts:67–86

(subscription: WaveEventSubscription<T>)

}

function waveEventSubscribeSingle<T extends WaveEventName>(subscription: WaveEventSubscription<T>): () => void {
    // console.log("waveEventSubscribeSingle", subscription);
    if (subscription.handler == null) {
        return () => {};
    }
    const id: string = crypto.randomUUID();
    let subjects = waveEventSubjects.get(subscription.eventType);
    if (subjects == null) {
        subjects = [];
        waveEventSubjects.set(subscription.eventType, subjects);
    }
    const subcont: WaveEventSubjectContainer = {
        id,
        handler: subscription.handler as (event: WaveEvent) => void,
        scope: subscription.scope,
    };
    subjects.push(subcont);
    updateWaveEventSub(subscription.eventType);
    return () => waveEventUnsubscribe({ id, eventType: subscription.eventType });
}

function waveEventUnsubscribe(...unsubscribes: WaveEventUnsubscribe[]) {
    const eventTypeSet = new Set<string>();