Method push

packages/runtime/src/async-queue.ts:42–45

(item: T)

  private progressWaiters: Array<() => void> = [];

  push(item: T): void {
    if (!this.canEnqueue()) return;
    this.enqueue(item);
  }

  /**
   * Enqueue one item and resolve only after the consumer has fully processed