it-pipe - npm Package Compare versions

Comparing version 2.0.2 to 2.0.3

dist/src/index.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAEA,OAAO,KAAK,KAAK,EAAE,MAAM,iBAAiB,CAAA;AAE1C,eAAO,MAAM,OAAO,WAAY,GAAG,QAMlC,CAAA;AAED,eAAO,MAAM,UAAU,QAAS,GAAG,0BAMlC,CAAA;AAED,eAAO,MAAM,QAAQ,yDAA2D,GAAG,4CAElF,CAAA;AAqBD,oBAAY,MAAM,CAAC,CAAC,IAAI,EAAE,CAAC,MAAM,CAAC,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,CAAC,EAAE,GAAG,EAAE,GAAG,CAAC,CAAA;AACpF,oBAAY,SAAS,CAAC,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,GAAG,CAAC,CAAA;AACvE,oBAAY,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,CAAC,EAAE,GAAG,EAAE,CAAC,CAAC,CAAA;AAE7D,wBAAgB,IAAI,CAAC,CAAC,EACpB,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,GACf,EAAE,CAAC,MAAM,CAAC,CAAC,CAAC,CAAA;AAEf,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EACvB,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GACjB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAC1B,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAC7B,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GACjB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAChC,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EACnC,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EACtC,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,OAAO,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAClB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EACzC,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,OAAO,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACxB,MAAM,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GACjB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAC5C,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,OAAO,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACxB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAC/C,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,OAAO,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACxB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAEA,OAAO,KAAK,KAAK,EAAE,MAAM,iBAAiB,CAAA;AAE1C,eAAO,MAAM,OAAO,WAAY,GAAG,QAMlC,CAAA;AAED,eAAO,MAAM,UAAU,QAAS,GAAG,0BAMlC,CAAA;AAED,eAAO,MAAM,QAAQ,yDAA2D,GAAG,4CAElF,CAAA;AA0BD,oBAAY,MAAM,CAAC,CAAC,IAAI,EAAE,CAAC,MAAM,CAAC,CAAC,CAAC,GAAG,CAAC,MAAM,EAAE,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,CAAC,EAAE,GAAG,EAAE,GAAG,CAAC,CAAA;AACpF,oBAAY,SAAS,CAAC,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,CAAC,EAAE,CAAC,EAAE,GAAG,CAAC,CAAA;AACvE,oBAAY,IAAI,CAAC,CAAC,EAAE,CAAC,IAAI,EAAE,CAAC,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAAG,EAAE,CAAC,MAAM,CAAC,CAAC,EAAE,GAAG,EAAE,CAAC,CAAC,CAAA;AAE7D,wBAAgB,IAAI,CAAC,CAAC,EACpB,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,GACf,EAAE,CAAC,MAAM,CAAC,CAAC,CAAC,CAAA;AAEf,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EACvB,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GACjB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAC1B,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAC7B,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GACjB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAChC,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EACnC,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EACtC,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,OAAO,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAClB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EACzC,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,OAAO,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACxB,MAAM,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GACjB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAC5C,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,OAAO,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACxB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA;AAEJ,wBAAgB,IAAI,CAAC,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,EAC/C,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,EAChB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,OAAO,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACxB,MAAM,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACvB,KAAK,EAAE,SAAS,CAAC,CAAC,EAAE,CAAC,CAAC,EACtB,KAAK,EAAE,IAAI,CAAC,CAAC,EAAE,CAAC,CAAC,GAChB,CAAC,CAAA"}

dist/src/index.js

@@ -29,3 +29,7 @@ import { pushable } from 'it-pushable';
             });
-            return merge(stream, duplex.source);
+            const sourceWrap = async function* () {
+                yield* duplex.source;
+                stream.end();
+            };
+            return merge(stream, sourceWrap());
         }
@@ -32,0 +36,0 @@ return duplex.source;

dist/src/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,QAAQ,EAAE,MAAM,aAAa,CAAA;AACtC,OAAO,KAAK,MAAM,UAAU,CAAA;AAG5B,MAAM,CAAC,MAAM,OAAO,GAAG,CAAC,GAAG,GAAQ,EAAE,EAAE;IACrC,IAAI,GAAG,CAAA;IACP,OAAO,GAAG,CAAC,MAAM,GAAG,CAAC,EAAE;QACrB,GAAG,GAAG,GAAG,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,CAAA;KACvB;IACD,OAAO,GAAG,CAAA;AACZ,CAAC,CAAA;AAED,MAAM,CAAC,MAAM,UAAU,GAAG,CAAC,GAAQ,EAAyB,EAAE;IAC5D,OAAO,GAAG,IAAI,IAAI,IAAI,CACpB,OAAO,GAAG,CAAC,MAAM,CAAC,aAAa,CAAC,KAAK,UAAU;QAC/C,OAAO,GAAG,CAAC,MAAM,CAAC,QAAQ,CAAC,KAAK,UAAU;QAC1C,OAAO,GAAG,CAAC,IAAI,KAAK,UAAU,CAAC,mBAAmB;KACnD,CAAA;AACH,CAAC,CAAA;AAED,MAAM,CAAC,MAAM,QAAQ,GAAG,CAAmD,GAAQ,EAA2C,EAAE;IAC9H,OAAO,GAAG,IAAI,IAAI,IAAI,OAAO,GAAG,CAAC,IAAI,KAAK,UAAU,IAAI,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC,CAAA;AAChF,CAAC,CAAA;AAED,MAAM,gBAAgB,GAAG,CAAW,MAAW,EAAE,EAAE;IACjD,OAAO,CAAC,MAAW,EAAsB,EAAE;QACzC,MAAM,CAAC,GAAG,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;QAE7B,IAAI,CAAC,CAAC,IAAI,IAAI,IAAI,EAAE;YAClB,MAAM,MAAM,GAAG,QAAQ,EAAW,CAAA;YAClC,CAAC,CAAC,IAAI,CAAC,GAAG,EAAE;gBACV,MAAM,CAAC,GAAG,EAAE,CAAA;YACd,CAAC,EAAE,CAAC,GAAU,EAAE,EAAE;gBAChB,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;YACjB,CAAC,CAAC,CAAA;YAEF,OAAO,KAAK,CAAC,MAAM,EAAE,MAAM,CAAC,MAAM,CAAC,CAAA;SACpC;QAED,OAAO,MAAM,CAAC,MAAM,CAAA;IACtB,CAAC,CAAA;AACH,CAAC,CAAA;AA2FD,MAAM,UAAU,IAAI,CAAE,KAAU,EAAE,GAAG,IAAW;IAC9C,6DAA6D;IAC7D,IAAI,QAAQ,CAAC,KAAK,CAAC,EAAE;QACnB,MAAM,MAAM,GAAG,KAAK,CAAA;QACpB,KAAK,GAAG,GAAG,EAAE,CAAC,MAAM,CAAC,MAAM,CAAA;QAC7B,sCAAsC;KACrC;SAAM,IAAI,UAAU,CAAC,KAAK,CAAC,EAAE;QAC5B,MAAM,MAAM,GAAG,KAAK,CAAA;QACpB,KAAK,GAAG,GAAG,EAAE,CAAC,MAAM,CAAA;KACrB;IAED,MAAM,GAAG,GAAG,CAAC,KAAK,EAAE,GAAG,IAAI,CAAC,CAAA;IAE5B,IAAI,GAAG,CAAC,MAAM,GAAG,CAAC,EAAE;QAClB,iCAAiC;QACjC,IAAI,QAAQ,CAAC,GAAG,CAAC,GAAG,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,EAAE;YACjC,GAAG,CAAC,GAAG,CAAC,MAAM,GAAG,CAAC,CAAC,GAAG,GAAG,CAAC,GAAG,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,IAAI,CAAA;SAC/C;KACF;IAED,IAAI,GAAG,CAAC,MAAM,GAAG,CAAC,EAAE;QAClB,iFAAiF;QACjF,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,GAAG,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC,EAAE,EAAE;YACvC,IAAI,QAAQ,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,EAAE;gBACpB,GAAG,CAAC,CAAC,CAAC,GAAG,gBAAgB,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAA;aAClC;SACF;KACF;IAED,OAAO,OAAO,CAAC,GAAG,GAAG,CAAC,CAAA;AACxB,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,QAAQ,EAAE,MAAM,aAAa,CAAA;AACtC,OAAO,KAAK,MAAM,UAAU,CAAA;AAG5B,MAAM,CAAC,MAAM,OAAO,GAAG,CAAC,GAAG,GAAQ,EAAE,EAAE;IACrC,IAAI,GAAG,CAAA;IACP,OAAO,GAAG,CAAC,MAAM,GAAG,CAAC,EAAE;QACrB,GAAG,GAAG,GAAG,CAAC,KAAK,EAAE,CAAC,GAAG,CAAC,CAAA;KACvB;IACD,OAAO,GAAG,CAAA;AACZ,CAAC,CAAA;AAED,MAAM,CAAC,MAAM,UAAU,GAAG,CAAC,GAAQ,EAAyB,EAAE;IAC5D,OAAO,GAAG,IAAI,IAAI,IAAI,CACpB,OAAO,GAAG,CAAC,MAAM,CAAC,aAAa,CAAC,KAAK,UAAU;QAC/C,OAAO,GAAG,CAAC,MAAM,CAAC,QAAQ,CAAC,KAAK,UAAU;QAC1C,OAAO,GAAG,CAAC,IAAI,KAAK,UAAU,CAAC,mBAAmB;KACnD,CAAA;AACH,CAAC,CAAA;AAED,MAAM,CAAC,MAAM,QAAQ,GAAG,CAAmD,GAAQ,EAA2C,EAAE;IAC9H,OAAO,GAAG,IAAI,IAAI,IAAI,OAAO,GAAG,CAAC,IAAI,KAAK,UAAU,IAAI,UAAU,CAAC,GAAG,CAAC,MAAM,CAAC,CAAA;AAChF,CAAC,CAAA;AAED,MAAM,gBAAgB,GAAG,CAAW,MAA0B,EAAE,EAAE;IAChE,OAAO,CAAC,MAAW,EAAsB,EAAE;QACzC,MAAM,CAAC,GAAG,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,CAAA;QAE7B,IAAI,CAAC,CAAC,IAAI,IAAI,IAAI,EAAE;YAClB,MAAM,MAAM,GAAG,QAAQ,EAAW,CAAA;YAClC,CAAC,CAAC,IAAI,CAAC,GAAG,EAAE;gBACV,MAAM,CAAC,GAAG,EAAE,CAAA;YACd,CAAC,EAAE,CAAC,GAAU,EAAE,EAAE;gBAChB,MAAM,CAAC,GAAG,CAAC,GAAG,CAAC,CAAA;YACjB,CAAC,CAAC,CAAA;YAEF,MAAM,UAAU,GAAG,KAAK,SAAU,CAAC;gBACjC,KAAM,CAAC,CAAC,MAAM,CAAC,MAAM,CAAA;gBACrB,MAAM,CAAC,GAAG,EAAE,CAAA;YACd,CAAC,CAAA;YAED,OAAO,KAAK,CAAC,MAAM,EAAE,UAAU,EAAE,CAAC,CAAA;SACnC;QAED,OAAO,MAAM,CAAC,MAAM,CAAA;IACtB,CAAC,CAAA;AACH,CAAC,CAAA;AA2FD,MAAM,UAAU,IAAI,CAAE,KAAU,EAAE,GAAG,IAAW;IAC9C,6DAA6D;IAC7D,IAAI,QAAQ,CAAC,KAAK,CAAC,EAAE;QACnB,MAAM,MAAM,GAAG,KAAK,CAAA;QACpB,KAAK,GAAG,GAAG,EAAE,CAAC,MAAM,CAAC,MAAM,CAAA;QAC7B,sCAAsC;KACrC;SAAM,IAAI,UAAU,CAAC,KAAK,CAAC,EAAE;QAC5B,MAAM,MAAM,GAAG,KAAK,CAAA;QACpB,KAAK,GAAG,GAAG,EAAE,CAAC,MAAM,CAAA;KACrB;IAED,MAAM,GAAG,GAAG,CAAC,KAAK,EAAE,GAAG,IAAI,CAAC,CAAA;IAE5B,IAAI,GAAG,CAAC,MAAM,GAAG,CAAC,EAAE;QAClB,iCAAiC;QACjC,IAAI,QAAQ,CAAC,GAAG,CAAC,GAAG,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,EAAE;YACjC,GAAG,CAAC,GAAG,CAAC,MAAM,GAAG,CAAC,CAAC,GAAG,GAAG,CAAC,GAAG,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,IAAI,CAAA;SAC/C;KACF;IAED,IAAI,GAAG,CAAC,MAAM,GAAG,CAAC,EAAE;QAClB,iFAAiF;QACjF,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,GAAG,CAAC,MAAM,GAAG,CAAC,EAAE,CAAC,EAAE,EAAE;YACvC,IAAI,QAAQ,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,EAAE;gBACpB,GAAG,CAAC,CAAC,CAAC,GAAG,gBAAgB,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAA;aAClC;SACF;KACF;IAED,OAAO,OAAO,CAAC,GAAG,GAAG,CAAC,CAAA;AACxB,CAAC"}

package.json

 {
   "name": "it-pipe",
-  "version": "2.0.2",
+  "version": "2.0.3",
   "description": "Utility to \"pipe\" async iterables together",
@@ -126,2 +126,3 @@ "type": "module",
     "it-drain": "^1.0.5",
+    "p-defer": "^4.0.0",
     "streaming-iterables": "^6.0.0"
@@ -128,0 +129,0 @@ },

src/index.ts

@@ -25,3 +25,3 @@ import { pushable } from 'it-pushable'
 
-const duplexPipelineFn = <TSource> (duplex: any) => {
+const duplexPipelineFn = <TSource> (duplex: it.Duplex<TSource>) => {
   return (source: any): it.Source<TSource> => {
@@ -38,3 +38,8 @@ const p = duplex.sink(source)
 
-      return merge(stream, duplex.source)
+      const sourceWrap = async function * () {
+        yield * duplex.source
+        stream.end()
+      }
+
+      return merge(stream, sourceWrap())
     }
@@ -41,0 +46,0 @@

No alert changes

Improved metrics

Total package byte prevSize

21847

1.87%

Lines of code

226

3.67%

Worsened metrics

Dev dependency count

6

20%

No dependency changes