@naturalcycles/nodejs-lib/dist/stream/readable/readableMap.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.readableMap = void 0;
const node_stream_1 = require("node:stream");
const js_lib_1 = require("@naturalcycles/js-lib");
function readableMap(readable, mapper) {
    let i = -1;
    const stream = readable
        .on('error', err => stream.emit('error', err))
        .pipe(new node_stream_1.Transform({
        objectMode: true,
        async transform(chunk, _enc, cb) {
            try {
                const r = await mapper(chunk, ++i);
                if (r === js_lib_1.SKIP) {
                    cb();
                }
                else {
                    // _assert(r !== END, `readableMap END not supported`)
                    cb(null, r);
                }
            }
            catch (err) {
                console.error(err);
                cb(err);
            }
        },
    }));
    return stream;
}
exports.readableMap = readableMap;