export function asyncIterableToStream<T>(it: AsyncIterableIterator<T>) {
  return new ReadableStream({
    async pull(controller) {
      const {done, value} = await it.next()
      if (done) {
        controller.close()
      } else {
        controller.enqueue(value)
      }
    },
  })
}