wasm-rquickjs 0.3.4

// Copyright 2018-2022 the Deno authors. All rights reserved. MIT license.
// Copyright Joyent and Node contributors. All rights reserved. MIT license.

import { isIterable, isNodeStream, isWebStream } from "__wasm_rquickjs_builtin/internal/streams/utils";
import { pipelineImpl as pl } from "__wasm_rquickjs_builtin/internal/streams/pipeline";
import eos from "__wasm_rquickjs_builtin/internal/streams/end-of-stream";
import { validateBoolean } from "__wasm_rquickjs_builtin/internal/validators";

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) &&
            !isWebStream(lastArg)
        ) {
            const options = streams.pop();
            signal = options.signal;
            end = options.end;
        }

        if (Array.isArray(streams[0]) && streams.length === 1) {
            streams = streams[0];
        }

        pl(streams, (err, value) => {
            if (err) {
                reject(err);
            } else {
                resolve(value);
            }
        }, { signal, end });
    });
}

function finished(stream, opts) {
    let autoCleanup = false;
    if (opts?.cleanup) {
        validateBoolean(opts.cleanup, "cleanup");
        autoCleanup = opts.cleanup;
    }

    return new Promise((resolve, reject) => {
        const cleanup = eos(stream, opts, (err) => {
            if (autoCleanup) {
                cleanup();
            }

            if (err) {
                reject(err);
            } else {
                resolve();
            }
        });
    });
}

export default {
    finished,
    pipeline,
};
export { finished, pipeline };