{"version":3,"file":"index.cjs","names":[],"sources":["../../../../node_modules/end-of-stream/index.js"],"sourcesContent":["var once = require('once');\n\nvar noop = function() {};\n\nvar isRequest = function(stream) {\n\treturn stream.setHeader && typeof stream.abort === 'function';\n};\n\nvar isChildProcess = function(stream) {\n\treturn stream.stdio && Array.isArray(stream.stdio) && stream.stdio.length === 3\n};\n\nvar eos = function(stream, opts, callback) {\n\tif (typeof opts === 'function') return eos(stream, null, opts);\n\tif (!opts) opts = {};\n\n\tcallback = once(callback || noop);\n\n\tvar ws = stream._writableState;\n\tvar rs = stream._readableState;\n\tvar readable = opts.readable || (opts.readable !== false && stream.readable);\n\tvar writable = opts.writable || (opts.writable !== false && stream.writable);\n\tvar cancelled = false;\n\n\tvar onlegacyfinish = function() {\n\t\tif (!stream.writable) onfinish();\n\t};\n\n\tvar onfinish = function() {\n\t\twritable = false;\n\t\tif (!readable) callback.call(stream);\n\t};\n\n\tvar onend = function() {\n\t\treadable = false;\n\t\tif (!writable) callback.call(stream);\n\t};\n\n\tvar onexit = function(exitCode) {\n\t\tcallback.call(stream, exitCode ? new Error('exited with error code: ' + exitCode) : null);\n\t};\n\n\tvar onerror = function(err) {\n\t\tcallback.call(stream, err);\n\t};\n\n\tvar onclose = function() {\n\t\tprocess.nextTick(onclosenexttick);\n\t};\n\n\tvar onclosenexttick = function() {\n\t\tif (cancelled) return;\n\t\tif (readable && !(rs && (rs.ended && !rs.destroyed))) return callback.call(stream, new Error('premature close'));\n\t\tif (writable && !(ws && (ws.ended && !ws.destroyed))) return callback.call(stream, new Error('premature close'));\n\t};\n\n\tvar onrequest = function() {\n\t\tstream.req.on('finish', onfinish);\n\t};\n\n\tif (isRequest(stream)) {\n\t\tstream.on('complete', onfinish);\n\t\tstream.on('abort', onclose);\n\t\tif (stream.req) onrequest();\n\t\telse stream.on('request', onrequest);\n\t} else if (writable && !ws) { // legacy streams\n\t\tstream.on('end', onlegacyfinish);\n\t\tstream.on('close', onlegacyfinish);\n\t}\n\n\tif (isChildProcess(stream)) stream.on('exit', onexit);\n\n\tstream.on('end', onend);\n\tstream.on('finish', onfinish);\n\tif (opts.error !== false) stream.on('error', onerror);\n\tstream.on('close', onclose);\n\n\treturn function() {\n\t\tcancelled = true;\n\t\tstream.removeListener('complete', onfinish);\n\t\tstream.removeListener('abort', onclose);\n\t\tstream.removeListener('request', onrequest);\n\t\tif (stream.req) stream.req.removeListener('finish', onfinish);\n\t\tstream.removeListener('end', onlegacyfinish);\n\t\tstream.removeListener('close', onlegacyfinish);\n\t\tstream.removeListener('finish', onfinish);\n\t\tstream.removeListener('exit', onexit);\n\t\tstream.removeListener('end', onend);\n\t\tstream.removeListener('error', onerror);\n\t\tstream.removeListener('close', onclose);\n\t};\n};\n\nmodule.exports = eos;\n"],"x_google_ignoreList":[0],"mappings":";;;;;CAAA,IAAI;CAEJ,IAAI,OAAO,WAAW;CAEtB,IAAI,YAAY,SAAS,QAAQ;AAChC,SAAO,OAAO,aAAa,OAAO,OAAO,UAAU;;CAGpD,IAAI,iBAAiB,SAAS,QAAQ;AACrC,SAAO,OAAO,SAAS,MAAM,QAAQ,OAAO,MAAM,IAAI,OAAO,MAAM,WAAW;;CAG/E,IAAI,MAAM,SAAS,QAAQ,MAAM,UAAU;AAC1C,MAAI,OAAO,SAAS,WAAY,QAAO,IAAI,QAAQ,MAAM,KAAK;AAC9D,MAAI,CAAC,KAAM,QAAO,EAAE;AAEpB,aAAW,KAAK,YAAY,KAAK;EAEjC,IAAI,KAAK,OAAO;EAChB,IAAI,KAAK,OAAO;EAChB,IAAI,WAAW,KAAK,YAAa,KAAK,aAAa,SAAS,OAAO;EACnE,IAAI,WAAW,KAAK,YAAa,KAAK,aAAa,SAAS,OAAO;EACnE,IAAI,YAAY;EAEhB,IAAI,iBAAiB,WAAW;AAC/B,OAAI,CAAC,OAAO,SAAU,WAAU;;EAGjC,IAAI,WAAW,WAAW;AACzB,cAAW;AACX,OAAI,CAAC,SAAU,UAAS,KAAK,OAAO;;EAGrC,IAAI,QAAQ,WAAW;AACtB,cAAW;AACX,OAAI,CAAC,SAAU,UAAS,KAAK,OAAO;;EAGrC,IAAI,SAAS,SAAS,UAAU;AAC/B,YAAS,KAAK,QAAQ,2BAAW,IAAI,MAAM,6BAA6B,SAAS,GAAG,KAAK;;EAG1F,IAAI,UAAU,SAAS,KAAK;AAC3B,YAAS,KAAK,QAAQ,IAAI;;EAG3B,IAAI,UAAU,WAAW;AACxB,WAAQ,SAAS,gBAAgB;;EAGlC,IAAI,kBAAkB,WAAW;AAChC,OAAI,UAAW;AACf,OAAI,YAAY,EAAE,MAAO,GAAG,SAAS,CAAC,GAAG,WAAa,QAAO,SAAS,KAAK,wBAAQ,IAAI,MAAM,kBAAkB,CAAC;AAChH,OAAI,YAAY,EAAE,MAAO,GAAG,SAAS,CAAC,GAAG,WAAa,QAAO,SAAS,KAAK,wBAAQ,IAAI,MAAM,kBAAkB,CAAC;;EAGjH,IAAI,YAAY,WAAW;AAC1B,UAAO,IAAI,GAAG,UAAU,SAAS;;AAGlC,MAAI,UAAU,OAAO,EAAE;AACtB,UAAO,GAAG,YAAY,SAAS;AAC/B,UAAO,GAAG,SAAS,QAAQ;AAC3B,OAAI,OAAO,IAAK,YAAW;OACtB,QAAO,GAAG,WAAW,UAAU;aAC1B,YAAY,CAAC,IAAI;AAC3B,UAAO,GAAG,OAAO,eAAe;AAChC,UAAO,GAAG,SAAS,eAAe;;AAGnC,MAAI,eAAe,OAAO,CAAE,QAAO,GAAG,QAAQ,OAAO;AAErD,SAAO,GAAG,OAAO,MAAM;AACvB,SAAO,GAAG,UAAU,SAAS;AAC7B,MAAI,KAAK,UAAU,MAAO,QAAO,GAAG,SAAS,QAAQ;AACrD,SAAO,GAAG,SAAS,QAAQ;AAE3B,SAAO,WAAW;AACjB,eAAY;AACZ,UAAO,eAAe,YAAY,SAAS;AAC3C,UAAO,eAAe,SAAS,QAAQ;AACvC,UAAO,eAAe,WAAW,UAAU;AAC3C,OAAI,OAAO,IAAK,QAAO,IAAI,eAAe,UAAU,SAAS;AAC7D,UAAO,eAAe,OAAO,eAAe;AAC5C,UAAO,eAAe,SAAS,eAAe;AAC9C,UAAO,eAAe,UAAU,SAAS;AACzC,UAAO,eAAe,QAAQ,OAAO;AACrC,UAAO,eAAe,OAAO,MAAM;AACnC,UAAO,eAAe,SAAS,QAAQ;AACvC,UAAO,eAAe,SAAS,QAAQ;;;AAIzC,QAAO,UAAU"}