Method enqueueSessionMutation

packages/runtime/src/runtime-kernel.ts:497–525

(
    ids: readonly string[],
    operation: () => Promise<T> | T,
  )

  }

  private async enqueueSessionMutation<T>(
    ids: readonly string[],
    operation: () => Promise<T> | T,
  ): Promise<T> {
    const precedingMutations = ids.map(
      (sessionId) => this.sessionMutationTails.get(sessionId) ?? Promise.resolve(),
    );
    const preceding = Promise.all(precedingMutations).then(() => undefined);
    let complete!: () => void;
    const completion = new Promise<void>((resolve) => {
      complete = resolve;
    });
    const tail = preceding.then(() => completion);
    for (const sessionId of ids) this.sessionMutationTails.set(sessionId, tail);
    void tail.then(() => {
      for (const sessionId of ids) {
        if (this.sessionMutationTails.get(sessionId) === tail) {
          this.sessionMutationTails.delete(sessionId);
        }
      }
    });

    try {
      await preceding;
      return await operation();
    } finally {
      complete();
    }
  }

  private takeExecutionClaim(
    sessionId: string,