Method pull

packages/shared/src/queue.ts:57–84

(id: string)

  }

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

    const items = this.queues.get(id)

    if (items?.length) {
      const item = items.shift()!

      if (items.length === 0) {
        this.queues.delete(id)
      }

      return item
    }

    return new Promise<T>((resolve, reject) => {
      const waitingPulls = this.waiters.get(id)

      const pending = [resolve, reject] as const

      if (waitingPulls) {
        waitingPulls.push(pending)
      }
      else {
        this.waiters.set(id, [pending])
      }
    })
  }

  close({ id, reason }: AsyncIdQueueCloseOptions = {}): void {
    if (id === undefined) {