Method subscribe

src/lib/progress-store.ts:94–112

(id: string, callback: (message: ProgressMessage) => void, sendExisting: boolean = true)

  }

  subscribe(id: string, callback: (message: ProgressMessage) => void, sendExisting: boolean = true): () => void {
    const execution = this.executions.get(id);
    if (!execution) {
      console.warn(`No execution found for id: ${id}`);
      return () => {};
    }

    execution.subscribers.add(callback);

    // Send all existing messages to the new subscriber only if requested
    if (sendExisting) {
      execution.messages.forEach((msg) => callback(msg));
    }

    // Return unsubscribe function
    return () => {
      execution.subscribers.delete(callback);
    };
  }

  getMessages(id: string): ProgressMessage[] {
    const execution = this.executions.get(id);