Function ensureAsyncIterable

out/cli.cjs:77978–77993

(stream4)

        controller.close();
      } else {
        controller.enqueue(value);
      }
    },
    cancel
  });
}
function ensureAsyncIterable(stream4) {
  if (isReadableStream4(stream4)) {
    makeAsyncIterable2(stream4);
    return {
      cancel: () => stream4.cancel(),
      iterable: stream4
    };
  } else {
    return {
      cancel: async () => {
        stream4.socket.end();
      },
      iterable: stream4