permessage-deflate support in websocket about undici HOT 1 CLOSED

class Queue {
  queue = []
  compress = false

  run () {
    while (this.queue.length) {
      const item = this.queue[0]

      if (!item.done) return

      this.queue.shift()
    }
  }

  add (item) {
    if (Buffer.isBuffer(item)) {
      this.queue.push({ done: true, value: item })
    } else if (item instanceof Blob) {
      const promise = item.arrayBuffer()
      const queued = { done: false, value: promise }

      promise.then((value) => {
        queued.done = true
        queued.value = Buffer.from(value)
        this.run()
      })

      this.queue.push(queued)
    }
  }
}