Function concat

out/cli.cjs:75706–75733

(sources)

  if (source instanceof Uint8Array) {
    return import_node_stream2.Readable.from(Buffer.from(source));
  } else if (isBlob3(source)) {
    return toStream(getRawContent(source));
  } else {
    return ensureNodeStream(source);
  }
}
async function concat(sources) {
  return function() {
    const streams = sources.map((x5) => typeof x5 === "function" ? x5() : x5).map(toStream);
    return import_node_stream2.Readable.from(function() {
      return __asyncGenerator(this, arguments, function* () {
        var _a5, e_1, _b2, _c2;
        for (const stream4 of streams) {
          try {
            for (var _d2 = true, stream_1 = (e_1 = void 0, __asyncValues(stream4)), stream_1_1; stream_1_1 = yield __await(stream_1.next()), _a5 = stream_1_1.done, !_a5; _d2 = true) {
              _c2 = stream_1_1.value;
              _d2 = false;
              const chunk = _c2;
              yield yield __await(chunk);
            }
          } catch (e_1_1) {
            e_1 = { error: e_1_1 };
          } finally {
            try {
              if (!_d2 && !_a5 && (_b2 = stream_1.return)) yield __await(_b2.call(stream_1));
            } finally {
              if (e_1) throw e_1.error;
            }
          }
        }
      });