import { isIterable, isNodeStream } from "../internal/streams/utils.mjs";import { pipelineImpl as pl } from "../internal/streams/pipeline.mjs";import eos from "../internal/streams/end-of-stream.mjs";
function pipeline(...streams) { return new Promise((resolve, reject) => { let signal; let end; const lastArg = streams[streams.length - 1]; if ( lastArg && typeof lastArg === "object" && !isNodeStream(lastArg) && !isIterable(lastArg) ) { const options = streams.pop(); signal = options.signal; end = options.end; }
pl(streams, (err, value) => { if (err) { reject(err); } else { resolve(value); } }, { signal, end }); });}
function finished(stream, opts) { return new Promise((resolve, reject) => { eos(stream, opts, (err) => { if (err) { reject(err); } else { resolve(); } }); });}
export default { finished, pipeline,};export { finished, pipeline };