Method removeSubscriber

src/node/services/sessionTimingService.ts:194–210

(workspaceId: string)

  }

  removeSubscriber(workspaceId: string): void {
    const current = this.subscriberCounts.get(workspaceId) ?? 0;
    const next = Math.max(0, current - 1);
    if (next === 0) {
      this.subscriberCounts.delete(workspaceId);

      const interval = this.tickIntervals.get(workspaceId);
      if (interval) {
        clearInterval(interval);
        this.tickIntervals.delete(workspaceId);
      }

      this.clearDeltaEmitState(workspaceId);
      return;
    }
    this.subscriberCounts.set(workspaceId, next);
  }

  onStatsChange(listener: (workspaceId: string) => void): void {
    this.emitter.on("change", listener);