{"version":3,"sources":["jsdelivr-header.js","/npm/stream-functions@1.0.0/js/index.js"],"names":[],"mappings":"AAAA;AACA;AACA;AACA;AACA;AACA;AACA,ACNA,aACA,OAAO,eAAe,QAAS,aAAc,CAAE,OAAO,IACtD,MAAM,SAAW,QAAQ,UACzB,SAAS,cAAc,GACnB,MAAO,CAAC,EAAM,EAAK,KACf,IACI,EAAG,GACH,GACJ,CACA,MAAO,GACH,EAAK,EACT,EAER,CAEA,SAAS,OAAO,GACZ,MAAM,EAAS,IAAI,SAAS,UAAU,CAClC,YAAY,IAOhB,OALA,EAAO,WAAa,QAAQ,eAAe,IACnC,EAAU,IACV,EAAO,KAAK,EAChB,IAEG,CACX,CAEA,SAAS,WAAW,GAChB,MAAM,EAAS,IAAI,SAAS,UAAU,CAClC,YAAY,IAYhB,OAVA,EAAO,WAAa,CAAC,EAAO,EAAU,KAClC,EAAG,GACE,MAAM,IACP,EAAO,KAAK,GACZ,GAAM,IAEL,OAAO,IACR,EAAO,KAAK,QAAS,EAAI,GAC3B,EAEC,CACX,CAEA,SAAS,IAAI,GACT,MAAM,EAAS,IAAI,SAAS,UAAU,CAClC,YAAY,IAKhB,OAHA,EAAO,WAAa,QAAQ,eAAe,IACvC,EAAO,KAAK,EAAG,GAAO,IAEnB,CACX,CAEA,SAAS,OAAO,GACZ,IAAI,EAAO,GACX,MAAM,EAAS,IAAI,SAAS,UAAU,CAClC,YAAY,IAahB,OAXA,EAAO,WAAa,QAAQ,eAAe,IACnC,EAAK,QAAU,IACf,EAAO,KAAK,GACZ,EAAO,IAEX,EAAK,KAAK,EAAM,IAEpB,EAAO,OAAU,IACb,EAAO,KAAK,GACZ,GAAM,EAEH,CACX,CAEA,SAAS,UACL,MAAM,EAAS,IAAI,SAAS,UAAU,CAClC,YAAY,IAOhB,OALA,EAAO,WAAa,QAAQ,eAAe,IACvC,EAAM,SAAS,IACX,EAAO,KAAK,EAAE,GAChB,IAEC,CACX,CArEA,QAAQ,cAAgB,cAYxB,QAAQ,OAAS,OAiBjB,QAAQ,WAAa,WAUrB,QAAQ,IAAM,IAmBd,QAAQ,OAAS,OAYjB,QAAQ,QAAU","file":"/npm/stream-functions@1.0.0/js/index.js","sourceRoot":"","sourcesContent":["/**\n * Minified by jsDelivr using Terser v5.39.0.\n * Original file: /npm/stream-functions@1.0.0/js/index.js\n *\n * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files\n */\n","\"use strict\";\nObject.defineProperty(exports, \"__esModule\", { value: true });\nconst stream_1 = require(\"stream\");\nfunction syncTransform(fn) {\n    return (data, enc, next) => {\n        try {\n            fn(data);\n            next();\n        }\n        catch (err) {\n            next(err);\n        }\n    };\n}\nexports.syncTransform = syncTransform;\nfunction filter(predicate) {\n    const transf = new stream_1.Transform({\n        objectMode: true,\n    });\n    transf._transform = exports.syncTransform((chunk) => {\n        if (predicate(chunk)) {\n            transf.push(chunk);\n        }\n    });\n    return transf;\n}\nexports.filter = filter;\nfunction promiseMap(fn) {\n    const transf = new stream_1.Transform({\n        objectMode: true,\n    });\n    transf._transform = (chunk, encoding, next) => {\n        fn(chunk)\n            .then((res) => {\n            transf.push(res);\n            next();\n        })\n            .catch((err) => {\n            transf.emit(\"error\", err);\n        });\n    };\n    return transf;\n}\nexports.promiseMap = promiseMap;\nfunction map(fn) {\n    const transf = new stream_1.Transform({\n        objectMode: true,\n    });\n    transf._transform = exports.syncTransform((chunk) => {\n        transf.push(fn(chunk));\n    });\n    return transf;\n}\nexports.map = map;\nfunction buffer(bufferSize) {\n    let buff = [];\n    const transf = new stream_1.Transform({\n        objectMode: true,\n    });\n    transf._transform = exports.syncTransform((chunk) => {\n        if (buff.length >= bufferSize) {\n            transf.push(buff);\n            buff = [];\n        }\n        buff.push(chunk);\n    });\n    transf._flush = (done) => {\n        transf.push(buff);\n        done();\n    };\n    return transf;\n}\nexports.buffer = buffer;\nfunction flatten() {\n    const transf = new stream_1.Transform({\n        objectMode: true,\n    });\n    transf._transform = exports.syncTransform((chunk) => {\n        chunk.forEach((c) => {\n            transf.push(c);\n        });\n    });\n    return transf;\n}\nexports.flatten = flatten;\n"]}