Method constructor

src/coordinator/ipc-run-coordinator.ts:26–35

(private channel: IpcChannel)

  private pending = new Map<string, (result: CoordinatorResult) => void>();

  constructor(private channel: IpcChannel) {
    this.channel.on('message', (message: any) => {
      if (message?.type !== 'coordinator:result') return;
      const resolve = this.pending.get(message.reqId);
      if (resolve) {
        this.pending.delete(message.reqId);
        resolve(message);
      }
    });
  }

  shouldRun(key: string, ttlMs: number): Promise<boolean> {
    const reqId = createID();