Method push

packages/shared/src/queue.ts:33–55

(id: string, item: T)

  }

  push(id: string, item: T): void {
    this.assertOpen(id)

    const pending = this.waiters.get(id)

    if (pending?.length) {
      pending.shift()![0](item)

      if (pending.length === 0) {
        this.waiters.delete(id)
      }
    }
    else {
      const items = this.queues.get(id)

      if (items) {
        items.push(item)
      }
      else {
        this.queues.set(id, [item])
      }
    }
  }

  async pull(id: string): Promise<T> {
    this.assertOpen(id)