multipasta - npm Package Compare versions

Comparing version 0.2.5 to 0.2.6

dist/cjs/node.js

@@ -49,2 +49,3 @@ "use strict";
     });
+    let currentFile;
     this._parser = MP.make({
@@ -63,2 +64,3 @@ ...config,
         const file = new FileStream(info, this);
+        currentFile = file;
         this.push(file);
@@ -69,2 +71,3 @@ this.emit("file", file);
           if (chunk === null && !this._canWrite) {
+            currentFile = undefined;
             this._resume();
@@ -76,2 +79,3 @@ }
         this.emit("error", error);
+        currentFile?.emit("error", error);
       },
@@ -78,0 +82,0 @@ onDone: () => {

dist/cjs/node.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"node.js","names":["MP","_interopRequireWildcard","require","_nodeStream","_getRequireWildcardCache","e","WeakMap","r","t","__esModule","default","has","get","n","__proto__","a","Object","defineProperty","getOwnPropertyDescriptor","u","prototype","hasOwnProperty","call","i","set","MultipastaStream","Duplex","_parser","_canWrite","_writeCallback","constructor","config","readableObjectMode","make","onField","info","value","field","_tag","push","emit","onFile","file","FileStream","chunk","_resume","onError","error","onDone","undefined","callback","_read","_size","_write","encoding","write","Uint8Array","Buffer","from","_final","end","exports","Readable","_parent","filename"],"sources":["../../src/node.ts"],"sourcesContent":[null],"mappings":";;;;;;;;;;;;;AAEA,IAAAA,EAAA,gBAAAC,uBAAA,eAAAC,OAAA;AACA,IAAAC,WAAA,gBAAAD,OAAA;AAA8C,SAAAE,yBAAAC,CAAA;EAAA,yBAAAC,OAAA;EAAA,IAAAC,CAAA,OAAAD,OAAA;IAAAE,CAAA,OAAAF,OAAA;EAAA,QAAAF,wBAAA,YAAAA,CAAAC,CAAA;IAAA,OAAAA,CAAA,GAAAG,CAAA,GAAAD,CAAA;EAAA,GAAAF,CAAA;AAAA;AAAA,SAAAJ,wBAAAI,CAAA,EAAAE,CAAA;EAAA,KAAAA,CAAA,IAAAF,CAAA,IAAAA,CAAA,CAAAI,UAAA,SAAAJ,CAAA;EAAA,aAAAA,CAAA,uBAAAA,CAAA,yBAAAA,CAAA;IAAAK,OAAA,EAAAL;EAAA;EAAA,IAAAG,CAAA,GAAAJ,wBAAA,CAAAG,CAAA;EAAA,IAAAC,CAAA,IAAAA,CAAA,CAAAG,GAAA,CAAAN,CAAA,UAAAG,CAAA,CAAAI,GAAA,CAAAP,CAAA;EAAA,IAAAQ,CAAA;MAAAC,SAAA;IAAA;IAAAC,CAAA,GAAAC,MAAA,CAAAC,cAAA,IAAAD,MAAA,CAAAE,wBAAA;EAAA,SAAAC,CAAA,IAAAd,CAAA,oBAAAc,CAAA,IAAAH,MAAA,CAAAI,SAAA,CAAAC,cAAA,CAAAC,IAAA,CAAAjB,CAAA,EAAAc,CAAA;IAAA,IAAAI,CAAA,GAAAR,CAAA,GAAAC,MAAA,CAAAE,wBAAA,CAAAb,CAAA,EAAAc,CAAA;IAAAI,CAAA,KAAAA,CAAA,CAAAX,GAAA,IAAAW,CAAA,CAAAC,GAAA,IAAAR,MAAA,CAAAC,cAAA,CAAAJ,CAAA,EAAAM,CAAA,EAAAI,CAAA,IAAAV,CAAA,CAAAM,CAAA,IAAAd,CAAA,CAAAc,CAAA;EAAA;EAAA,OAAAN,CAAA,CAAAH,OAAA,GAAAL,CAAA,EAAAG,CAAA,IAAAA,CAAA,CAAAgB,GAAA,CAAAnB,CAAA,EAAAQ,CAAA,GAAAA,CAAA;AAAA;AAsCxC,MAAOY,gBAAiB,SAAQtB,WAAA,CAAAuB,MAAM;EAClCC,OAAO;EACfC,SAAS,GAAG,IAAI;EACRC,cAAc;EAEtBC,YAAYC,MAAkB;IAC5B,KAAK,CAAC;MAAEC,kBAAkB,EAAE;IAAI,CAAE,CAAC;IACnC,IAAI,CAACL,OAAO,GAAG3B,EAAE,CAACiC,IAAI,CAAC;MACrB,GAAIF,MAAc;MAClBG,OAAO,EAAEA,CAACC,IAAI,EAAEC,KAAK,KAAI;QACvB,MAAMC,KAAK,GAAU;UAAEC,IAAI,EAAE,OAAO;UAAEH,IAAI;UAAEC;QAAK,CAAE;QACnD,IAAI,CAACG,IAAI,CAACF,KAAK,CAAC;QAChB,IAAI,CAACG,IAAI,CAAC,OAAO,EAAEH,KAAK,CAAC;MAC3B,CAAC;MACDI,MAAM,EAAEN,IAAI,IAAG;QACb,MAAMO,IAAI,GAAG,IAAIC,UAAU,CAACR,IAAI,EAAE,IAAI,CAAC;QACvC,IAAI,CAACI,IAAI,CAACG,IAAI,CAAC;QACf,IAAI,CAACF,IAAI,CAAC,MAAM,EAAEE,IAAI,CAAC;QACvB,OAAOE,KAAK,IAAG;UACb,IAAI,CAAChB,SAAS,GAAGc,IAAI,CAACH,IAAI,CAACK,KAAK,CAAC;UACjC,IAAIA,KAAK,KAAK,IAAI,IAAI,CAAC,IAAI,CAAChB,SAAS,EAAE;YACrC,IAAI,CAACiB,OAAO,EAAE;;QAElB,CAAC;MACH,CAAC;MACDC,OAAO,EAAEC,KAAK,IAAG;QACf,IAAI,CAACP,IAAI,CAAC,OAAO,EAAEO,KAAK,CAAC;MAC3B,CAAC;MACDC,MAAM,EAAEA,CAAA,KAAK;QACX,IAAI,CAACT,IAAI,CAAC,IAAI,CAAC;MACjB;KACD,CAAC;EACJ;EAEAM,OAAOA,CAAA;IACL,IAAI,CAACjB,SAAS,GAAG,IAAI;IACrB,IAAI,IAAI,CAACC,cAAc,KAAKoB,SAAS,EAAE;MACrC,MAAMC,QAAQ,GAAG,IAAI,CAACrB,cAAc;MACpC,IAAI,CAACA,cAAc,GAAGoB,SAAS;MAC/BC,QAAQ,EAAE;;EAEd;EAEAC,KAAKA,CAACC,KAAa,GAAG;EAEtBC,MAAMA,CACJT,KAAU,EACVU,QAAwB,EACxBJ,QAAoD;IAEpD,IAAI,CAACvB,OAAO,CAAC4B,KAAK,CAChBX,KAAK,YAAYY,UAAU,GAAGZ,KAAK,GAAGa,MAAM,CAACC,IAAI,CAACd,KAAK,EAAEU,QAAQ,CAAC,CACnE;IACD,IAAI,IAAI,CAAC1B,SAAS,EAAE;MAClBsB,QAAQ,EAAE;KACX,MAAM;MACL,IAAI,CAACrB,cAAc,GAAGqB,QAAQ;;EAElC;EAEAS,MAAMA,CAACT,QAAoD;IACzD,IAAI,CAACvB,OAAO,CAACiC,GAAG,EAAE;IAClBV,QAAQ,EAAE;EACZ;;AACDW,OAAA,CAAApC,gBAAA,GAAAA,gBAAA;AAEM,MAAMQ,IAAI,GAAIF,MAAkB,IACrC,IAAIN,gBAAgB,CAACM,MAAM,CAAC;AAAA8B,OAAA,CAAA5B,IAAA,GAAAA,IAAA;AAExB,MAAOU,UAAW,SAAQxC,WAAA,CAAA2D,QAAQ;EAI3B3B,IAAA;EACD4B,OAAA;EAJDzB,IAAI,GAAG,MAAM;EACb0B,QAAQ;EACjBlC,YACWK,IAAiB,EAClB4B,OAAyB;IAEjC,KAAK,EAAE;IAHE,KAAA5B,IAAI,GAAJA,IAAI;IACL,KAAA4B,OAAO,GAAPA,OAAO;IAGf,IAAI,CAACC,QAAQ,GAAG7B,IAAI,CAAC6B,QAAS;EAChC;EACAb,KAAKA,CAACC,KAAa;IACjB,IAAI,IAAI,CAACW,OAAO,CAACnC,SAAS,KAAK,KAAK,EAAE;MACpC,IAAI,CAACmC,OAAO,CAAClB,OAAO,EAAE;;EAE1B;;AACDgB,OAAA,CAAAlB,UAAA,GAAAA,UAAA"}
+{"version":3,"file":"node.js","names":["MP","_interopRequireWildcard","require","_nodeStream","_getRequireWildcardCache","e","WeakMap","r","t","__esModule","default","has","get","n","__proto__","a","Object","defineProperty","getOwnPropertyDescriptor","u","prototype","hasOwnProperty","call","i","set","MultipastaStream","Duplex","_parser","_canWrite","_writeCallback","constructor","config","readableObjectMode","currentFile","make","onField","info","value","field","_tag","push","emit","onFile","file","FileStream","chunk","undefined","_resume","onError","error","onDone","callback","_read","_size","_write","encoding","write","Uint8Array","Buffer","from","_final","end","exports","Readable","_parent","filename"],"sources":["../../src/node.ts"],"sourcesContent":[null],"mappings":";;;;;;;;;;;;;AAEA,IAAAA,EAAA,gBAAAC,uBAAA,eAAAC,OAAA;AACA,IAAAC,WAAA,gBAAAD,OAAA;AAA8C,SAAAE,yBAAAC,CAAA;EAAA,yBAAAC,OAAA;EAAA,IAAAC,CAAA,OAAAD,OAAA;IAAAE,CAAA,OAAAF,OAAA;EAAA,QAAAF,wBAAA,YAAAA,CAAAC,CAAA;IAAA,OAAAA,CAAA,GAAAG,CAAA,GAAAD,CAAA;EAAA,GAAAF,CAAA;AAAA;AAAA,SAAAJ,wBAAAI,CAAA,EAAAE,CAAA;EAAA,KAAAA,CAAA,IAAAF,CAAA,IAAAA,CAAA,CAAAI,UAAA,SAAAJ,CAAA;EAAA,aAAAA,CAAA,uBAAAA,CAAA,yBAAAA,CAAA;IAAAK,OAAA,EAAAL;EAAA;EAAA,IAAAG,CAAA,GAAAJ,wBAAA,CAAAG,CAAA;EAAA,IAAAC,CAAA,IAAAA,CAAA,CAAAG,GAAA,CAAAN,CAAA,UAAAG,CAAA,CAAAI,GAAA,CAAAP,CAAA;EAAA,IAAAQ,CAAA;MAAAC,SAAA;IAAA;IAAAC,CAAA,GAAAC,MAAA,CAAAC,cAAA,IAAAD,MAAA,CAAAE,wBAAA;EAAA,SAAAC,CAAA,IAAAd,CAAA,oBAAAc,CAAA,IAAAH,MAAA,CAAAI,SAAA,CAAAC,cAAA,CAAAC,IAAA,CAAAjB,CAAA,EAAAc,CAAA;IAAA,IAAAI,CAAA,GAAAR,CAAA,GAAAC,MAAA,CAAAE,wBAAA,CAAAb,CAAA,EAAAc,CAAA;IAAAI,CAAA,KAAAA,CAAA,CAAAX,GAAA,IAAAW,CAAA,CAAAC,GAAA,IAAAR,MAAA,CAAAC,cAAA,CAAAJ,CAAA,EAAAM,CAAA,EAAAI,CAAA,IAAAV,CAAA,CAAAM,CAAA,IAAAd,CAAA,CAAAc,CAAA;EAAA;EAAA,OAAAN,CAAA,CAAAH,OAAA,GAAAL,CAAA,EAAAG,CAAA,IAAAA,CAAA,CAAAgB,GAAA,CAAAnB,CAAA,EAAAQ,CAAA,GAAAA,CAAA;AAAA;AAsCxC,MAAOY,gBAAiB,SAAQtB,WAAA,CAAAuB,MAAM;EAClCC,OAAO;EACfC,SAAS,GAAG,IAAI;EACRC,cAAc;EAEtBC,YAAYC,MAAkB;IAC5B,KAAK,CAAC;MAAEC,kBAAkB,EAAE;IAAI,CAAE,CAAC;IACnC,IAAIC,WAAmC;IACvC,IAAI,CAACN,OAAO,GAAG3B,EAAE,CAACkC,IAAI,CAAC;MACrB,GAAIH,MAAc;MAClBI,OAAO,EAAEA,CAACC,IAAI,EAAEC,KAAK,KAAI;QACvB,MAAMC,KAAK,GAAU;UAAEC,IAAI,EAAE,OAAO;UAAEH,IAAI;UAAEC;QAAK,CAAE;QACnD,IAAI,CAACG,IAAI,CAACF,KAAK,CAAC;QAChB,IAAI,CAACG,IAAI,CAAC,OAAO,EAAEH,KAAK,CAAC;MAC3B,CAAC;MACDI,MAAM,EAAEN,IAAI,IAAG;QACb,MAAMO,IAAI,GAAG,IAAIC,UAAU,CAACR,IAAI,EAAE,IAAI,CAAC;QACvCH,WAAW,GAAGU,IAAI;QAClB,IAAI,CAACH,IAAI,CAACG,IAAI,CAAC;QACf,IAAI,CAACF,IAAI,CAAC,MAAM,EAAEE,IAAI,CAAC;QACvB,OAAOE,KAAK,IAAG;UACb,IAAI,CAACjB,SAAS,GAAGe,IAAI,CAACH,IAAI,CAACK,KAAK,CAAC;UACjC,IAAIA,KAAK,KAAK,IAAI,IAAI,CAAC,IAAI,CAACjB,SAAS,EAAE;YACrCK,WAAW,GAAGa,SAAS;YACvB,IAAI,CAACC,OAAO,EAAE;;QAElB,CAAC;MACH,CAAC;MACDC,OAAO,EAAEC,KAAK,IAAG;QACf,IAAI,CAACR,IAAI,CAAC,OAAO,EAAEQ,KAAK,CAAC;QACzBhB,WAAW,EAAEQ,IAAI,CAAC,OAAO,EAAEQ,KAAK,CAAC;MACnC,CAAC;MACDC,MAAM,EAAEA,CAAA,KAAK;QACX,IAAI,CAACV,IAAI,CAAC,IAAI,CAAC;MACjB;KACD,CAAC;EACJ;EAEAO,OAAOA,CAAA;IACL,IAAI,CAACnB,SAAS,GAAG,IAAI;IACrB,IAAI,IAAI,CAACC,cAAc,KAAKiB,SAAS,EAAE;MACrC,MAAMK,QAAQ,GAAG,IAAI,CAACtB,cAAc;MACpC,IAAI,CAACA,cAAc,GAAGiB,SAAS;MAC/BK,QAAQ,EAAE;;EAEd;EAEAC,KAAKA,CAACC,KAAa,GAAG;EAEtBC,MAAMA,CACJT,KAAU,EACVU,QAAwB,EACxBJ,QAAoD;IAEpD,IAAI,CAACxB,OAAO,CAAC6B,KAAK,CAChBX,KAAK,YAAYY,UAAU,GAAGZ,KAAK,GAAGa,MAAM,CAACC,IAAI,CAACd,KAAK,EAAEU,QAAQ,CAAC,CACnE;IACD,IAAI,IAAI,CAAC3B,SAAS,EAAE;MAClBuB,QAAQ,EAAE;KACX,MAAM;MACL,IAAI,CAACtB,cAAc,GAAGsB,QAAQ;;EAElC;EAEAS,MAAMA,CAACT,QAAoD;IACzD,IAAI,CAACxB,OAAO,CAACkC,GAAG,EAAE;IAClBV,QAAQ,EAAE;EACZ;;AACDW,OAAA,CAAArC,gBAAA,GAAAA,gBAAA;AAEM,MAAMS,IAAI,GAAIH,MAAkB,IACrC,IAAIN,gBAAgB,CAACM,MAAM,CAAC;AAAA+B,OAAA,CAAA5B,IAAA,GAAAA,IAAA;AAExB,MAAOU,UAAW,SAAQzC,WAAA,CAAA4D,QAAQ;EAI3B3B,IAAA;EACD4B,OAAA;EAJDzB,IAAI,GAAG,MAAM;EACb0B,QAAQ;EACjBnC,YACWM,IAAiB,EAClB4B,OAAyB;IAEjC,KAAK,EAAE;IAHE,KAAA5B,IAAI,GAAJA,IAAI;IACL,KAAA4B,OAAO,GAAPA,OAAO;IAGf,IAAI,CAACC,QAAQ,GAAG7B,IAAI,CAAC6B,QAAS;EAChC;EACAb,KAAKA,CAACC,KAAa;IACjB,IAAI,IAAI,CAACW,OAAO,CAACpC,SAAS,KAAK,KAAK,EAAE;MACpC,IAAI,CAACoC,OAAO,CAACjB,OAAO,EAAE;;EAE1B;;AACDe,OAAA,CAAAlB,UAAA,GAAAA,UAAA"}

dist/dts/node.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"node.d.ts","sourceRoot":"","sources":["../../src/node.ts"],"names":[],"mappings":";;;AACA,OAAO,KAAK,EAAE,mBAAmB,EAAE,MAAM,WAAW,CAAA;AACpD,OAAO,KAAK,EAAE,MAAM,YAAY,CAAA;AAChC,OAAO,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,aAAa,CAAA;AAE9C,YAAY,EAAE,cAAc,EAAE,QAAQ,EAAE,MAAM,YAAY,CAAA;AAC1D,OAAO,EAAE,WAAW,EAAE,MAAM,YAAY,CAAA;AAExC,MAAM,MAAM,IAAI,GAAG,KAAK,GAAG,UAAU,CAAA;AAErC,MAAM,WAAW,KAAK;IACpB,QAAQ,CAAC,IAAI,EAAE,OAAO,CAAA;IACtB,QAAQ,CAAC,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAA;IAC1B,QAAQ,CAAC,KAAK,EAAE,UAAU,CAAA;CAC3B;AAED,MAAM,WAAW,gBAAiB,SAAQ,MAAM;IAC9C,CAAC,MAAM,CAAC,aAAa,CAAC,IAAI,qBAAqB,CAAC,IAAI,CAAC,CAAA;IAErD,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,CAAC,KAAK,EAAE,KAAK,KAAK,IAAI,GAAG,IAAI,CAAA;IAC1D,EAAE,CAAC,KAAK,EAAE,MAAM,EAAE,QAAQ,EAAE,CAAC,IAAI,EAAE,UAAU,KAAK,IAAI,GAAG,IAAI,CAAA;IAC7D,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC9C,EAAE,CAAC,KAAK,EAAE,MAAM,EAAE,QAAQ,EAAE,CAAC,IAAI,EAAE,IAAI,KAAK,IAAI,GAAG,IAAI,CAAA;IACvD,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC9C,EAAE,CAAC,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC5C,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,CAAC,GAAG,EAAE,EAAE,CAAC,cAAc,KAAK,IAAI,GAAG,IAAI,CAAA;IACpE,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC/C,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC9C,EAAE,CAAC,KAAK,EAAE,MAAM,EAAE,QAAQ,EAAE,CAAC,GAAG,EAAE,QAAQ,KAAK,IAAI,GAAG,IAAI,CAAA;IAC1D,EAAE,CAAC,KAAK,EAAE,UAAU,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IACjD,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC/C,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,QAAQ,EAAE,CAAC,GAAG,EAAE,QAAQ,KAAK,IAAI,GAAG,IAAI,CAAA;IAC5D,EAAE,CAAC,KAAK,EAAE,MAAM,GAAG,MAAM,EAAE,QAAQ,EAAE,CAAC,GAAG,IAAI,EAAE,GAAG,EAAE,KAAK,IAAI,GAAG,IAAI,CAAA;IAEpE,IAAI,CAAC,IAAI,CAAC,EAAE,MAAM,GAAG,IAAI,GAAG,IAAI,CAAA;CACjC;AAED,MAAM,MAAM,UAAU,GAAG,IAAI,CAAC,EAAE,CAAC,UAAU,EAAE,SAAS,CAAC,GAAG;IACxD,QAAQ,CAAC,OAAO,EAAE,mBAAmB,CAAA;CACtC,CAAA;AAED,qBAAa,gBAAiB,SAAQ,MAAM;IAC1C,OAAO,CAAC,OAAO,CAAW;IAC1B,SAAS,UAAO;IAChB,OAAO,CAAC,cAAc,CAA0B;gBAEpC,MAAM,EAAE,UAAU;IA6B9B,OAAO;IASP,KAAK,CAAC,KAAK,EAAE,MAAM;IAEnB,MAAM,CACJ,KAAK,EAAE,GAAG,EACV,QAAQ,EAAE,cAAc,EACxB,QAAQ,EAAE,CAAC,KAAK,CAAC,EAAE,KAAK,GAAG,IAAI,GAAG,SAAS,KAAK,IAAI,GACnD,IAAI;IAWP,MAAM,CAAC,QAAQ,EAAE,CAAC,KAAK,CAAC,EAAE,KAAK,GAAG,IAAI,GAAG,SAAS,KAAK,IAAI,GAAG,IAAI;CAInE;AAED,eAAO,MAAM,IAAI,WAAY,UAAU,KAAG,gBACZ,CAAA;AAE9B,qBAAa,UAAW,SAAQ,QAAQ;IAIpC,QAAQ,CAAC,IAAI,EAAE,EAAE,CAAC,QAAQ;IAC1B,OAAO,CAAC,OAAO;IAJjB,QAAQ,CAAC,IAAI,UAAS;IACtB,QAAQ,CAAC,QAAQ,EAAE,MAAM,CAAA;gBAEd,IAAI,EAAE,EAAE,CAAC,QAAQ,EAClB,OAAO,EAAE,gBAAgB;IAKnC,KAAK,CAAC,KAAK,EAAE,MAAM;CAKpB"}
+{"version":3,"file":"node.d.ts","sourceRoot":"","sources":["../../src/node.ts"],"names":[],"mappings":";;;AACA,OAAO,KAAK,EAAE,mBAAmB,EAAE,MAAM,WAAW,CAAA;AACpD,OAAO,KAAK,EAAE,MAAM,YAAY,CAAA;AAChC,OAAO,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,aAAa,CAAA;AAE9C,YAAY,EAAE,cAAc,EAAE,QAAQ,EAAE,MAAM,YAAY,CAAA;AAC1D,OAAO,EAAE,WAAW,EAAE,MAAM,YAAY,CAAA;AAExC,MAAM,MAAM,IAAI,GAAG,KAAK,GAAG,UAAU,CAAA;AAErC,MAAM,WAAW,KAAK;IACpB,QAAQ,CAAC,IAAI,EAAE,OAAO,CAAA;IACtB,QAAQ,CAAC,IAAI,EAAE,EAAE,CAAC,QAAQ,CAAA;IAC1B,QAAQ,CAAC,KAAK,EAAE,UAAU,CAAA;CAC3B;AAED,MAAM,WAAW,gBAAiB,SAAQ,MAAM;IAC9C,CAAC,MAAM,CAAC,aAAa,CAAC,IAAI,qBAAqB,CAAC,IAAI,CAAC,CAAA;IAErD,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,CAAC,KAAK,EAAE,KAAK,KAAK,IAAI,GAAG,IAAI,CAAA;IAC1D,EAAE,CAAC,KAAK,EAAE,MAAM,EAAE,QAAQ,EAAE,CAAC,IAAI,EAAE,UAAU,KAAK,IAAI,GAAG,IAAI,CAAA;IAC7D,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC9C,EAAE,CAAC,KAAK,EAAE,MAAM,EAAE,QAAQ,EAAE,CAAC,IAAI,EAAE,IAAI,KAAK,IAAI,GAAG,IAAI,CAAA;IACvD,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC9C,EAAE,CAAC,KAAK,EAAE,KAAK,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC5C,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,CAAC,GAAG,EAAE,EAAE,CAAC,cAAc,KAAK,IAAI,GAAG,IAAI,CAAA;IACpE,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC/C,EAAE,CAAC,KAAK,EAAE,OAAO,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC9C,EAAE,CAAC,KAAK,EAAE,MAAM,EAAE,QAAQ,EAAE,CAAC,GAAG,EAAE,QAAQ,KAAK,IAAI,GAAG,IAAI,CAAA;IAC1D,EAAE,CAAC,KAAK,EAAE,UAAU,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IACjD,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,QAAQ,EAAE,MAAM,IAAI,GAAG,IAAI,CAAA;IAC/C,EAAE,CAAC,KAAK,EAAE,QAAQ,EAAE,QAAQ,EAAE,CAAC,GAAG,EAAE,QAAQ,KAAK,IAAI,GAAG,IAAI,CAAA;IAC5D,EAAE,CAAC,KAAK,EAAE,MAAM,GAAG,MAAM,EAAE,QAAQ,EAAE,CAAC,GAAG,IAAI,EAAE,GAAG,EAAE,KAAK,IAAI,GAAG,IAAI,CAAA;IAEpE,IAAI,CAAC,IAAI,CAAC,EAAE,MAAM,GAAG,IAAI,GAAG,IAAI,CAAA;CACjC;AAED,MAAM,MAAM,UAAU,GAAG,IAAI,CAAC,EAAE,CAAC,UAAU,EAAE,SAAS,CAAC,GAAG;IACxD,QAAQ,CAAC,OAAO,EAAE,mBAAmB,CAAA;CACtC,CAAA;AAED,qBAAa,gBAAiB,SAAQ,MAAM;IAC1C,OAAO,CAAC,OAAO,CAAW;IAC1B,SAAS,UAAO;IAChB,OAAO,CAAC,cAAc,CAA0B;gBAEpC,MAAM,EAAE,UAAU;IAiC9B,OAAO;IASP,KAAK,CAAC,KAAK,EAAE,MAAM;IAEnB,MAAM,CACJ,KAAK,EAAE,GAAG,EACV,QAAQ,EAAE,cAAc,EACxB,QAAQ,EAAE,CAAC,KAAK,CAAC,EAAE,KAAK,GAAG,IAAI,GAAG,SAAS,KAAK,IAAI,GACnD,IAAI;IAWP,MAAM,CAAC,QAAQ,EAAE,CAAC,KAAK,CAAC,EAAE,KAAK,GAAG,IAAI,GAAG,SAAS,KAAK,IAAI,GAAG,IAAI;CAInE;AAED,eAAO,MAAM,IAAI,WAAY,UAAU,KAAG,gBACZ,CAAA;AAE9B,qBAAa,UAAW,SAAQ,QAAQ;IAIpC,QAAQ,CAAC,IAAI,EAAE,EAAE,CAAC,QAAQ;IAC1B,OAAO,CAAC,OAAO;IAJjB,QAAQ,CAAC,IAAI,UAAS;IACtB,QAAQ,CAAC,QAAQ,EAAE,MAAM,CAAA;gBAEd,IAAI,EAAE,EAAE,CAAC,QAAQ,EAClB,OAAO,EAAE,gBAAgB;IAKnC,KAAK,CAAC,KAAK,EAAE,MAAM;CAKpB"}

dist/esm/node.js

@@ -12,2 +12,3 @@ import * as MP from "./index.js";
     });
+    let currentFile;
     this._parser = MP.make({
@@ -26,2 +27,3 @@ ...config,
         const file = new FileStream(info, this);
+        currentFile = file;
         this.push(file);
@@ -32,2 +34,3 @@ this.emit("file", file);
           if (chunk === null && !this._canWrite) {
+            currentFile = undefined;
             this._resume();
@@ -39,2 +42,3 @@ }
         this.emit("error", error);
+        currentFile?.emit("error", error);
       },
@@ -41,0 +45,0 @@ onDone: () => {

dist/esm/node.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"node.js","names":["MP","Duplex","Readable","decodeField","MultipastaStream","_parser","_canWrite","_writeCallback","constructor","config","readableObjectMode","make","onField","info","value","field","_tag","push","emit","onFile","file","FileStream","chunk","_resume","onError","error","onDone","undefined","callback","_read","_size","_write","encoding","write","Uint8Array","Buffer","from","_final","end","_parent","filename"],"sources":["../../src/node.ts"],"sourcesContent":[null],"mappings":"AAEA,OAAO,KAAKA,EAAE,MAAM,YAAY;AAChC,SAASC,MAAM,EAAEC,QAAQ,QAAQ,aAAa;AAG9C,SAASC,WAAW,QAAQ,YAAY;AAmCxC,OAAM,MAAOC,gBAAiB,SAAQH,MAAM;EAClCI,OAAO;EACfC,SAAS,GAAG,IAAI;EACRC,cAAc;EAEtBC,YAAYC,MAAkB;IAC5B,KAAK,CAAC;MAAEC,kBAAkB,EAAE;IAAI,CAAE,CAAC;IACnC,IAAI,CAACL,OAAO,GAAGL,EAAE,CAACW,IAAI,CAAC;MACrB,GAAIF,MAAc;MAClBG,OAAO,EAAEA,CAACC,IAAI,EAAEC,KAAK,KAAI;QACvB,MAAMC,KAAK,GAAU;UAAEC,IAAI,EAAE,OAAO;UAAEH,IAAI;UAAEC;QAAK,CAAE;QACnD,IAAI,CAACG,IAAI,CAACF,KAAK,CAAC;QAChB,IAAI,CAACG,IAAI,CAAC,OAAO,EAAEH,KAAK,CAAC;MAC3B,CAAC;MACDI,MAAM,EAAEN,IAAI,IAAG;QACb,MAAMO,IAAI,GAAG,IAAIC,UAAU,CAACR,IAAI,EAAE,IAAI,CAAC;QACvC,IAAI,CAACI,IAAI,CAACG,IAAI,CAAC;QACf,IAAI,CAACF,IAAI,CAAC,MAAM,EAAEE,IAAI,CAAC;QACvB,OAAOE,KAAK,IAAG;UACb,IAAI,CAAChB,SAAS,GAAGc,IAAI,CAACH,IAAI,CAACK,KAAK,CAAC;UACjC,IAAIA,KAAK,KAAK,IAAI,IAAI,CAAC,IAAI,CAAChB,SAAS,EAAE;YACrC,IAAI,CAACiB,OAAO,EAAE;;QAElB,CAAC;MACH,CAAC;MACDC,OAAO,EAAEC,KAAK,IAAG;QACf,IAAI,CAACP,IAAI,CAAC,OAAO,EAAEO,KAAK,CAAC;MAC3B,CAAC;MACDC,MAAM,EAAEA,CAAA,KAAK;QACX,IAAI,CAACT,IAAI,CAAC,IAAI,CAAC;MACjB;KACD,CAAC;EACJ;EAEAM,OAAOA,CAAA;IACL,IAAI,CAACjB,SAAS,GAAG,IAAI;IACrB,IAAI,IAAI,CAACC,cAAc,KAAKoB,SAAS,EAAE;MACrC,MAAMC,QAAQ,GAAG,IAAI,CAACrB,cAAc;MACpC,IAAI,CAACA,cAAc,GAAGoB,SAAS;MAC/BC,QAAQ,EAAE;;EAEd;EAEAC,KAAKA,CAACC,KAAa,GAAG;EAEtBC,MAAMA,CACJT,KAAU,EACVU,QAAwB,EACxBJ,QAAoD;IAEpD,IAAI,CAACvB,OAAO,CAAC4B,KAAK,CAChBX,KAAK,YAAYY,UAAU,GAAGZ,KAAK,GAAGa,MAAM,CAACC,IAAI,CAACd,KAAK,EAAEU,QAAQ,CAAC,CACnE;IACD,IAAI,IAAI,CAAC1B,SAAS,EAAE;MAClBsB,QAAQ,EAAE;KACX,MAAM;MACL,IAAI,CAACrB,cAAc,GAAGqB,QAAQ;;EAElC;EAEAS,MAAMA,CAACT,QAAoD;IACzD,IAAI,CAACvB,OAAO,CAACiC,GAAG,EAAE;IAClBV,QAAQ,EAAE;EACZ;;AAGF,OAAO,MAAMjB,IAAI,GAAIF,MAAkB,IACrC,IAAIL,gBAAgB,CAACK,MAAM,CAAC;AAE9B,OAAM,MAAOY,UAAW,SAAQnB,QAAQ;EAI3BW,IAAA;EACD0B,OAAA;EAJDvB,IAAI,GAAG,MAAM;EACbwB,QAAQ;EACjBhC,YACWK,IAAiB,EAClB0B,OAAyB;IAEjC,KAAK,EAAE;IAHE,KAAA1B,IAAI,GAAJA,IAAI;IACL,KAAA0B,OAAO,GAAPA,OAAO;IAGf,IAAI,CAACC,QAAQ,GAAG3B,IAAI,CAAC2B,QAAS;EAChC;EACAX,KAAKA,CAACC,KAAa;IACjB,IAAI,IAAI,CAACS,OAAO,CAACjC,SAAS,KAAK,KAAK,EAAE;MACpC,IAAI,CAACiC,OAAO,CAAChB,OAAO,EAAE;;EAE1B"}
+{"version":3,"file":"node.js","names":["MP","Duplex","Readable","decodeField","MultipastaStream","_parser","_canWrite","_writeCallback","constructor","config","readableObjectMode","currentFile","make","onField","info","value","field","_tag","push","emit","onFile","file","FileStream","chunk","undefined","_resume","onError","error","onDone","callback","_read","_size","_write","encoding","write","Uint8Array","Buffer","from","_final","end","_parent","filename"],"sources":["../../src/node.ts"],"sourcesContent":[null],"mappings":"AAEA,OAAO,KAAKA,EAAE,MAAM,YAAY;AAChC,SAASC,MAAM,EAAEC,QAAQ,QAAQ,aAAa;AAG9C,SAASC,WAAW,QAAQ,YAAY;AAmCxC,OAAM,MAAOC,gBAAiB,SAAQH,MAAM;EAClCI,OAAO;EACfC,SAAS,GAAG,IAAI;EACRC,cAAc;EAEtBC,YAAYC,MAAkB;IAC5B,KAAK,CAAC;MAAEC,kBAAkB,EAAE;IAAI,CAAE,CAAC;IACnC,IAAIC,WAAmC;IACvC,IAAI,CAACN,OAAO,GAAGL,EAAE,CAACY,IAAI,CAAC;MACrB,GAAIH,MAAc;MAClBI,OAAO,EAAEA,CAACC,IAAI,EAAEC,KAAK,KAAI;QACvB,MAAMC,KAAK,GAAU;UAAEC,IAAI,EAAE,OAAO;UAAEH,IAAI;UAAEC;QAAK,CAAE;QACnD,IAAI,CAACG,IAAI,CAACF,KAAK,CAAC;QAChB,IAAI,CAACG,IAAI,CAAC,OAAO,EAAEH,KAAK,CAAC;MAC3B,CAAC;MACDI,MAAM,EAAEN,IAAI,IAAG;QACb,MAAMO,IAAI,GAAG,IAAIC,UAAU,CAACR,IAAI,EAAE,IAAI,CAAC;QACvCH,WAAW,GAAGU,IAAI;QAClB,IAAI,CAACH,IAAI,CAACG,IAAI,CAAC;QACf,IAAI,CAACF,IAAI,CAAC,MAAM,EAAEE,IAAI,CAAC;QACvB,OAAOE,KAAK,IAAG;UACb,IAAI,CAACjB,SAAS,GAAGe,IAAI,CAACH,IAAI,CAACK,KAAK,CAAC;UACjC,IAAIA,KAAK,KAAK,IAAI,IAAI,CAAC,IAAI,CAACjB,SAAS,EAAE;YACrCK,WAAW,GAAGa,SAAS;YACvB,IAAI,CAACC,OAAO,EAAE;;QAElB,CAAC;MACH,CAAC;MACDC,OAAO,EAAEC,KAAK,IAAG;QACf,IAAI,CAACR,IAAI,CAAC,OAAO,EAAEQ,KAAK,CAAC;QACzBhB,WAAW,EAAEQ,IAAI,CAAC,OAAO,EAAEQ,KAAK,CAAC;MACnC,CAAC;MACDC,MAAM,EAAEA,CAAA,KAAK;QACX,IAAI,CAACV,IAAI,CAAC,IAAI,CAAC;MACjB;KACD,CAAC;EACJ;EAEAO,OAAOA,CAAA;IACL,IAAI,CAACnB,SAAS,GAAG,IAAI;IACrB,IAAI,IAAI,CAACC,cAAc,KAAKiB,SAAS,EAAE;MACrC,MAAMK,QAAQ,GAAG,IAAI,CAACtB,cAAc;MACpC,IAAI,CAACA,cAAc,GAAGiB,SAAS;MAC/BK,QAAQ,EAAE;;EAEd;EAEAC,KAAKA,CAACC,KAAa,GAAG;EAEtBC,MAAMA,CACJT,KAAU,EACVU,QAAwB,EACxBJ,QAAoD;IAEpD,IAAI,CAACxB,OAAO,CAAC6B,KAAK,CAChBX,KAAK,YAAYY,UAAU,GAAGZ,KAAK,GAAGa,MAAM,CAACC,IAAI,CAACd,KAAK,EAAEU,QAAQ,CAAC,CACnE;IACD,IAAI,IAAI,CAAC3B,SAAS,EAAE;MAClBuB,QAAQ,EAAE;KACX,MAAM;MACL,IAAI,CAACtB,cAAc,GAAGsB,QAAQ;;EAElC;EAEAS,MAAMA,CAACT,QAAoD;IACzD,IAAI,CAACxB,OAAO,CAACkC,GAAG,EAAE;IAClBV,QAAQ,EAAE;EACZ;;AAGF,OAAO,MAAMjB,IAAI,GAAIH,MAAkB,IACrC,IAAIL,gBAAgB,CAACK,MAAM,CAAC;AAE9B,OAAM,MAAOa,UAAW,SAAQpB,QAAQ;EAI3BY,IAAA;EACD0B,OAAA;EAJDvB,IAAI,GAAG,MAAM;EACbwB,QAAQ;EACjBjC,YACWM,IAAiB,EAClB0B,OAAyB;IAEjC,KAAK,EAAE;IAHE,KAAA1B,IAAI,GAAJA,IAAI;IACL,KAAA0B,OAAO,GAAPA,OAAO;IAGf,IAAI,CAACC,QAAQ,GAAG3B,IAAI,CAAC2B,QAAS;EAChC;EACAX,KAAKA,CAACC,KAAa;IACjB,IAAI,IAAI,CAACS,OAAO,CAAClC,SAAS,KAAK,KAAK,EAAE;MACpC,IAAI,CAACkC,OAAO,CAACf,OAAO,EAAE;;EAE1B"}

package.json

 {
   "name": "multipasta",
-  "version": "0.2.5",
+  "version": "0.2.6",
   "description": "",
@@ -5,0 +5,0 @@ "license": "MIT",

src/node.ts

@@ -49,2 +49,3 @@ /// <reference types="node" />
     super({ readableObjectMode: true })
+    let currentFile: FileStream | undefined
     this._parser = MP.make({
@@ -59,2 +60,3 @@ ...(config as any),
         const file = new FileStream(info, this)
+        currentFile = file
         this.push(file)
@@ -65,2 +67,3 @@ this.emit("file", file)
           if (chunk === null && !this._canWrite) {
+            currentFile = undefined
             this._resume()
@@ -72,2 +75,3 @@ }
         this.emit("error", error)
+        currentFile?.emit("error", error)
       },
@@ -74,0 +78,0 @@ onDone: () => {

No alert changes

Improved metrics

Total package byte prevSize

178569

0.37%

Lines of code

2977

0.4%

No dependency changes