Method pushAndWaitUntilConsumed

packages/runtime/src/async-queue.ts:52–58

* Enqueue one item and resolve only after the consumer has fully processed * that exact sequence. Unlike `push()`, an enqueue rejected by queue state is * observable by the producer.

(item: T)

   * observable by the producer.
   */
  pushAndWaitUntilConsumed(item: T): Promise<void> {
    if (this.err) return Promise.reject(this.err);
    if (this.consumerDetached) return Promise.reject(consumerDetachedError());
    if (this.closed) return Promise.reject(queueClosedError());
    const sequence = this.enqueue(item);
    return this.waitUntilConsumed(sequence);
  }

  /**
   * Wait through the producer boundary captured at call time. Items enqueued