@json2csv/whatwg - npm Package Compare versions

Comparing version 7.0.4 to 7.0.5

dist/cjs/AsyncParser.d.ts

 import type { ParserOptions, StreamParserOptions } from '@json2csv/plainjs';
+import { type AwaitableReadableStream } from './TransformStream.js';
 export default class JSON2CSVNodeAsyncParser<TRaw extends object, T extends object> {
@@ -14,4 +15,4 @@ private opts;
      */
-    parse(data: string | string | ArrayBufferView | Iterable<TRaw> | AsyncIterable<TRaw> | TRaw | ReadableStream<TRaw>): ReadableStream<string>;
+    parse(data: string | string | ArrayBufferView | Iterable<TRaw> | AsyncIterable<TRaw> | TRaw | ReadableStream<TRaw>): AwaitableReadableStream<string>;
 }
 //# sourceMappingURL=AsyncParser.d.ts.map

dist/cjs/AsyncParser.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"AsyncParser.d.ts","sourceRoot":"","sources":["../../src/AsyncParser.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,aAAa,EAAE,mBAAmB,EAAE,MAAM,mBAAmB,CAAC;AAG5E,MAAM,CAAC,OAAO,OAAO,uBAAuB,CAC1C,IAAI,SAAS,MAAM,EACnB,CAAC,SAAS,MAAM;IAEhB,OAAO,CAAC,IAAI,CAAyB;IACrC,OAAO,CAAC,SAAS,CAAsB;IACvC,OAAO,CAAC,gBAAgB,CAAC,CAAwB;IACjD,OAAO,CAAC,gBAAgB,CAAC,CAA0B;gBAEjD,IAAI,GAAE,aAAa,CAAC,IAAI,EAAE,CAAC,CAAM,EACjC,SAAS,GAAE,mBAAwB,EACnC,gBAAgB,CAAC,EAAE,eAAe,CAAC,IAAI,CAAC,EACxC,gBAAgB,CAAC,EAAE,eAAe,CAAC,MAAM,CAAC;IAQ5C;;;;;OAKG;IACH,KAAK,CACH,IAAI,EACA,MAAM,GACN,MAAM,GACN,eAAe,GACf,QAAQ,CAAC,IAAI,CAAC,GACd,aAAa,CAAC,IAAI,CAAC,GACnB,IAAI,GACJ,cAAc,CAAC,IAAI,CAAC;CA2C3B"}
+{"version":3,"file":"AsyncParser.d.ts","sourceRoot":"","sources":["../../src/AsyncParser.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,aAAa,EAAE,mBAAmB,EAAE,MAAM,mBAAmB,CAAC;AAC5E,OAAsC,EACpC,KAAK,uBAAuB,EAC7B,MAAM,sBAAsB,CAAC;AAE9B,MAAM,CAAC,OAAO,OAAO,uBAAuB,CAC1C,IAAI,SAAS,MAAM,EACnB,CAAC,SAAS,MAAM;IAEhB,OAAO,CAAC,IAAI,CAAyB;IACrC,OAAO,CAAC,SAAS,CAAsB;IACvC,OAAO,CAAC,gBAAgB,CAAC,CAAwB;IACjD,OAAO,CAAC,gBAAgB,CAAC,CAA0B;gBAEjD,IAAI,GAAE,aAAa,CAAC,IAAI,EAAE,CAAC,CAAM,EACjC,SAAS,GAAE,mBAAwB,EACnC,gBAAgB,CAAC,EAAE,eAAe,CAAC,IAAI,CAAC,EACxC,gBAAgB,CAAC,EAAE,eAAe,CAAC,MAAM,CAAC;IAQ5C;;;;;OAKG;IACH,KAAK,CACH,IAAI,EACA,MAAM,GACN,MAAM,GACN,eAAe,GACf,QAAQ,CAAC,IAAI,CAAC,GACd,aAAa,CAAC,IAAI,CAAC,GACnB,IAAI,GACJ,cAAc,CAAC,IAAI,CAAC,GACvB,uBAAuB,CAAC,MAAM,CAAC;CA0CnC"}

dist/cjs/AsyncParser.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"AsyncParser.js","sourceRoot":"","sources":["../../src/AsyncParser.ts"],"names":[],"mappings":";;;;;AACA,8EAAiE;AAEjE,MAAqB,uBAAuB;IAQ1C,YACE,OAA+B,EAAE,EACjC,YAAiC,EAAE,EACnC,gBAAwC,EACxC,gBAA0C;QAE1C,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,SAAS,GAAG,SAAS,CAAC;QAC3B,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;QACzC,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;IAC3C,CAAC;IAED;;;;;OAKG;IACH,KAAK,CACH,IAOwB;QAExB,IAAI,OAAO,IAAI,KAAK,QAAQ,IAAI,WAAW,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE;YACxD,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACd,UAAU,CAAC,OAAO,CAAC,IAAY,CAAC,CAAC;oBACjC,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;aAAM,IAAI,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;YAC9B,IAAI,CAAC,SAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YACjC,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACb,IAAoB;yBAClB,MAAM,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,IAAI,KAAK,IAAI,CAAC;yBAC/B,OAAO,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,UAAU,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC;oBAC/C,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;aAAM,IAAI,OAAO,IAAI,KAAK,QAAQ,IAAI,CAAC,CAAC,IAAI,YAAY,cAAc,CAAC,EAAE;YACxE,IAAI,CAAC,SAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YACjC,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACd,UAAU,CAAC,OAAO,CAAC,IAAY,CAAC,CAAC;oBACjC,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;QAED,IAAI,CAAC,CAAC,IAAI,YAAY,cAAc,CAAC,EAAE;YACrC,MAAM,IAAI,KAAK,CACb,yEAAyE,CAC1E,CAAC;SACH;QAED,MAAM,SAAS,GAAG,IAAI,4BAA6B,CACjD,IAAI,CAAC,IAAI,EACT,IAAI,CAAC,SAAS,EACd,IAAI,CAAC,gBAAgB,EACrB,IAAI,CAAC,gBAAgB,CACtB,CAAC;QACF,OAAO,IAAI,CAAC,WAAW,CAAC,SAAS,CAAC,CAAC;IACrC,CAAC;CACF;AA7ED,0CA6EC"}
+{"version":3,"file":"AsyncParser.js","sourceRoot":"","sources":["../../src/AsyncParser.ts"],"names":[],"mappings":";;;;;AACA,8EAE8B;AAE9B,MAAqB,uBAAuB;IAQ1C,YACE,OAA+B,EAAE,EACjC,YAAiC,EAAE,EACnC,gBAAwC,EACxC,gBAA0C;QAE1C,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,SAAS,GAAG,SAAS,CAAC;QAC3B,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;QACzC,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;IAC3C,CAAC;IAED;;;;;OAKG;IACH,KAAK,CACH,IAOwB;QAExB,IAAI,OAAO,IAAI,KAAK,QAAQ,IAAI,WAAW,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE;YACxD,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACd,UAAU,CAAC,OAAO,CAAC,IAAY,CAAC,CAAC;oBACjC,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;aAAM,IAAI,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;YAC9B,IAAI,CAAC,SAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YACjC,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACb,IAAoB;yBAClB,MAAM,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,IAAI,KAAK,IAAI,CAAC;yBAC/B,OAAO,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,UAAU,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC;oBAC/C,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;aAAM,IAAI,OAAO,IAAI,KAAK,QAAQ,IAAI,CAAC,CAAC,IAAI,YAAY,cAAc,CAAC,EAAE;YACxE,IAAI,CAAC,SAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YACjC,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACd,UAAU,CAAC,OAAO,CAAC,IAAY,CAAC,CAAC;oBACjC,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;QAED,IAAI,CAAC,CAAC,IAAI,YAAY,cAAc,CAAC,EAAE;YACrC,MAAM,IAAI,KAAK,CACb,yEAAyE,CAC1E,CAAC;SACH;QAED,MAAM,SAAS,GAAG,IAAI,4BAA6B,CACjD,IAAI,CAAC,IAAI,EACT,IAAI,CAAC,SAAS,EACd,IAAI,CAAC,gBAAgB,EACrB,IAAI,CAAC,gBAAgB,CACtB,CAAC;QACF,OAAO,IAAI,CAAC,WAAW,CAAC,SAAS,CAAoC,CAAC;IACxE,CAAC;CACF;AA7ED,0CA6EC"}

dist/cjs/index.d.ts

 export type { ParserOptions, StreamParserOptions } from '@json2csv/plainjs';
 export { default as AsyncParser } from './AsyncParser.js';
-export { default as TransformStream } from './TransformStream.js';
+export { default as TransformStream, type AwaitableReadableStream, } from './TransformStream.js';
 //# sourceMappingURL=index.d.ts.map

dist/cjs/index.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA,YAAY,EAAE,aAAa,EAAE,mBAAmB,EAAE,MAAM,mBAAmB,CAAC;AAC5E,OAAO,EAAE,OAAO,IAAI,WAAW,EAAE,MAAM,kBAAkB,CAAC;AAC1D,OAAO,EAAE,OAAO,IAAI,eAAe,EAAE,MAAM,sBAAsB,CAAC"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA,YAAY,EAAE,aAAa,EAAE,mBAAmB,EAAE,MAAM,mBAAmB,CAAC;AAC5E,OAAO,EAAE,OAAO,IAAI,WAAW,EAAE,MAAM,kBAAkB,CAAC;AAC1D,OAAO,EACL,OAAO,IAAI,eAAe,EAC1B,KAAK,uBAAuB,GAC7B,MAAM,sBAAsB,CAAC"}

dist/cjs/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";;;;;;AACA,mDAA0D;AAAjD,8HAAA,OAAO,OAAe;AAC/B,2DAAkE;AAAzD,sIAAA,OAAO,OAAmB"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":";;;;;;AACA,mDAA0D;AAAjD,8HAAA,OAAO,OAAe;AAC/B,2DAG8B;AAF5B,sIAAA,OAAO,OAAmB"}

dist/cjs/TransformStream.d.ts

 import { type ParserOptions, type StreamParserOptions } from '@json2csv/plainjs';
-interface AwaitableReadableStream<T> extends ReadableStream<T> {
+export interface AwaitableReadableStream<T> extends ReadableStream<T> {
     promise(): Promise<string>;
@@ -13,3 +13,2 @@ }
 }
-export {};
 //# sourceMappingURL=TransformStream.d.ts.map

dist/cjs/TransformStream.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"TransformStream.d.ts","sourceRoot":"","sources":["../../src/TransformStream.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,KAAK,aAAa,EAElB,KAAK,mBAAmB,EACzB,MAAM,mBAAmB,CAAC;AAwC3B,UAAU,uBAAuB,CAAC,CAAC,CAAE,SAAQ,cAAc,CAAC,CAAC,CAAC;IAC5D,OAAO,IAAI,OAAO,CAAC,MAAM,CAAC,CAAC;CAC5B;AAED,MAAM,CAAC,OAAO,OAAO,6BAA6B,CAC9C,IAAI,SAAS,MAAM,EACnB,CAAC,SAAS,MAAM,CAElB,SAAQ,eAAe,CAAC,IAAI,EAAE,MAAM,CACpC,YAAW,eAAe,CAAC,IAAI,EAAE,MAAM,CAAC,EAAE,WAAW;IAErD,SAAkB,QAAQ,EAAG,uBAAuB,CAAC,MAAM,CAAC,CAAC;IAC7D,OAAO,CAAC,QAAQ,CAAC,CAAmB;gBAGlC,IAAI,GAAE,aAAa,CAAC,IAAI,EAAE,CAAC,CAAM,EACjC,SAAS,GAAE,mBAAwB,EACnC,gBAAgB,CAAC,EAAE,eAAe,CAAC,IAAI,CAAC,EACxC,gBAAgB,CAAC,EAAE,eAAe,CAAC,MAAM,CAAC;IAiCrC,gBAAgB,CACrB,IAAI,EAAE,MAAM,EACZ,QAAQ,EAAE,kCAAkC,GAAG,IAAI,EACnD,OAAO,CAAC,EAAE,OAAO,GAAG,uBAAuB,GAAG,SAAS,GACtD,IAAI;IAIA,aAAa,CAAC,KAAK,EAAE,KAAK,GAAG,OAAO;IAIpC,mBAAmB,CACxB,IAAI,EAAE,MAAM,EACZ,QAAQ,EAAE,kCAAkC,GAAG,IAAI,EACnD,OAAO,CAAC,EAAE,OAAO,GAAG,oBAAoB,GAAG,SAAS,GACnD,IAAI;CAGR"}
+{"version":3,"file":"TransformStream.d.ts","sourceRoot":"","sources":["../../src/TransformStream.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,KAAK,aAAa,EAElB,KAAK,mBAAmB,EACzB,MAAM,mBAAmB,CAAC;AAwC3B,MAAM,WAAW,uBAAuB,CAAC,CAAC,CAAE,SAAQ,cAAc,CAAC,CAAC,CAAC;IACnE,OAAO,IAAI,OAAO,CAAC,MAAM,CAAC,CAAC;CAC5B;AAED,MAAM,CAAC,OAAO,OAAO,6BAA6B,CAC9C,IAAI,SAAS,MAAM,EACnB,CAAC,SAAS,MAAM,CAElB,SAAQ,eAAe,CAAC,IAAI,EAAE,MAAM,CACpC,YAAW,eAAe,CAAC,IAAI,EAAE,MAAM,CAAC,EAAE,WAAW;IAErD,SAAkB,QAAQ,EAAG,uBAAuB,CAAC,MAAM,CAAC,CAAC;IAC7D,OAAO,CAAC,QAAQ,CAAC,CAAmB;gBAGlC,IAAI,GAAE,aAAa,CAAC,IAAI,EAAE,CAAC,CAAM,EACjC,SAAS,GAAE,mBAAwB,EACnC,gBAAgB,CAAC,EAAE,eAAe,CAAC,IAAI,CAAC,EACxC,gBAAgB,CAAC,EAAE,eAAe,CAAC,MAAM,CAAC;IAiCrC,gBAAgB,CACrB,IAAI,EAAE,MAAM,EACZ,QAAQ,EAAE,kCAAkC,GAAG,IAAI,EACnD,OAAO,CAAC,EAAE,OAAO,GAAG,uBAAuB,GAAG,SAAS,GACtD,IAAI;IAIA,aAAa,CAAC,KAAK,EAAE,KAAK,GAAG,OAAO;IAIpC,mBAAmB,CACxB,IAAI,EAAE,MAAM,EACZ,QAAQ,EAAE,kCAAkC,GAAG,IAAI,EACnD,OAAO,CAAC,EAAE,OAAO,GAAG,oBAAoB,GAAG,SAAS,GACnD,IAAI;CAGR"}

dist/mjs/AsyncParser.d.ts

 import type { ParserOptions, StreamParserOptions } from '@json2csv/plainjs';
+import { type AwaitableReadableStream } from './TransformStream.js';
 export default class JSON2CSVNodeAsyncParser<TRaw extends object, T extends object> {
@@ -14,4 +15,4 @@ private opts;
      */
-    parse(data: string | string | ArrayBufferView | Iterable<TRaw> | AsyncIterable<TRaw> | TRaw | ReadableStream<TRaw>): ReadableStream<string>;
+    parse(data: string | string | ArrayBufferView | Iterable<TRaw> | AsyncIterable<TRaw> | TRaw | ReadableStream<TRaw>): AwaitableReadableStream<string>;
 }
 //# sourceMappingURL=AsyncParser.d.ts.map

dist/mjs/AsyncParser.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"AsyncParser.d.ts","sourceRoot":"","sources":["../../src/AsyncParser.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,aAAa,EAAE,mBAAmB,EAAE,MAAM,mBAAmB,CAAC;AAG5E,MAAM,CAAC,OAAO,OAAO,uBAAuB,CAC1C,IAAI,SAAS,MAAM,EACnB,CAAC,SAAS,MAAM;IAEhB,OAAO,CAAC,IAAI,CAAyB;IACrC,OAAO,CAAC,SAAS,CAAsB;IACvC,OAAO,CAAC,gBAAgB,CAAC,CAAwB;IACjD,OAAO,CAAC,gBAAgB,CAAC,CAA0B;gBAEjD,IAAI,GAAE,aAAa,CAAC,IAAI,EAAE,CAAC,CAAM,EACjC,SAAS,GAAE,mBAAwB,EACnC,gBAAgB,CAAC,EAAE,eAAe,CAAC,IAAI,CAAC,EACxC,gBAAgB,CAAC,EAAE,eAAe,CAAC,MAAM,CAAC;IAQ5C;;;;;OAKG;IACH,KAAK,CACH,IAAI,EACA,MAAM,GACN,MAAM,GACN,eAAe,GACf,QAAQ,CAAC,IAAI,CAAC,GACd,aAAa,CAAC,IAAI,CAAC,GACnB,IAAI,GACJ,cAAc,CAAC,IAAI,CAAC;CA2C3B"}
+{"version":3,"file":"AsyncParser.d.ts","sourceRoot":"","sources":["../../src/AsyncParser.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,aAAa,EAAE,mBAAmB,EAAE,MAAM,mBAAmB,CAAC;AAC5E,OAAsC,EACpC,KAAK,uBAAuB,EAC7B,MAAM,sBAAsB,CAAC;AAE9B,MAAM,CAAC,OAAO,OAAO,uBAAuB,CAC1C,IAAI,SAAS,MAAM,EACnB,CAAC,SAAS,MAAM;IAEhB,OAAO,CAAC,IAAI,CAAyB;IACrC,OAAO,CAAC,SAAS,CAAsB;IACvC,OAAO,CAAC,gBAAgB,CAAC,CAAwB;IACjD,OAAO,CAAC,gBAAgB,CAAC,CAA0B;gBAEjD,IAAI,GAAE,aAAa,CAAC,IAAI,EAAE,CAAC,CAAM,EACjC,SAAS,GAAE,mBAAwB,EACnC,gBAAgB,CAAC,EAAE,eAAe,CAAC,IAAI,CAAC,EACxC,gBAAgB,CAAC,EAAE,eAAe,CAAC,MAAM,CAAC;IAQ5C;;;;;OAKG;IACH,KAAK,CACH,IAAI,EACA,MAAM,GACN,MAAM,GACN,eAAe,GACf,QAAQ,CAAC,IAAI,CAAC,GACd,aAAa,CAAC,IAAI,CAAC,GACnB,IAAI,GACJ,cAAc,CAAC,IAAI,CAAC,GACvB,uBAAuB,CAAC,MAAM,CAAC;CA0CnC"}

dist/mjs/AsyncParser.js

@@ -1,2 +0,2 @@
-import JSON2CSVWHATWGTransformStream from './TransformStream.js';
+import JSON2CSVWHATWGTransformStream, {} from './TransformStream.js';
 export default class JSON2CSVNodeAsyncParser {
@@ -3,0 +3,0 @@ constructor(opts = {}, asyncOpts = {}, writableStrategy, readableStrategy) {

dist/mjs/AsyncParser.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"AsyncParser.js","sourceRoot":"","sources":["../../src/AsyncParser.ts"],"names":[],"mappings":"AACA,OAAO,6BAA6B,MAAM,sBAAsB,CAAC;AAEjE,MAAM,CAAC,OAAO,OAAO,uBAAuB;IAQ1C,YACE,OAA+B,EAAE,EACjC,YAAiC,EAAE,EACnC,gBAAwC,EACxC,gBAA0C;QAE1C,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,SAAS,GAAG,SAAS,CAAC;QAC3B,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;QACzC,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;IAC3C,CAAC;IAED;;;;;OAKG;IACH,KAAK,CACH,IAOwB;QAExB,IAAI,OAAO,IAAI,KAAK,QAAQ,IAAI,WAAW,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE;YACxD,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACd,UAAU,CAAC,OAAO,CAAC,IAAY,CAAC,CAAC;oBACjC,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;aAAM,IAAI,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;YAC9B,IAAI,CAAC,SAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YACjC,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACb,IAAoB;yBAClB,MAAM,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,IAAI,KAAK,IAAI,CAAC;yBAC/B,OAAO,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,UAAU,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC;oBAC/C,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;aAAM,IAAI,OAAO,IAAI,KAAK,QAAQ,IAAI,CAAC,CAAC,IAAI,YAAY,cAAc,CAAC,EAAE;YACxE,IAAI,CAAC,SAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YACjC,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACd,UAAU,CAAC,OAAO,CAAC,IAAY,CAAC,CAAC;oBACjC,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;QAED,IAAI,CAAC,CAAC,IAAI,YAAY,cAAc,CAAC,EAAE;YACrC,MAAM,IAAI,KAAK,CACb,yEAAyE,CAC1E,CAAC;SACH;QAED,MAAM,SAAS,GAAG,IAAI,6BAA6B,CACjD,IAAI,CAAC,IAAI,EACT,IAAI,CAAC,SAAS,EACd,IAAI,CAAC,gBAAgB,EACrB,IAAI,CAAC,gBAAgB,CACtB,CAAC;QACF,OAAO,IAAI,CAAC,WAAW,CAAC,SAAS,CAAC,CAAC;IACrC,CAAC;CACF"}
+{"version":3,"file":"AsyncParser.js","sourceRoot":"","sources":["../../src/AsyncParser.ts"],"names":[],"mappings":"AACA,OAAO,6BAA6B,EAAE,EAErC,MAAM,sBAAsB,CAAC;AAE9B,MAAM,CAAC,OAAO,OAAO,uBAAuB;IAQ1C,YACE,OAA+B,EAAE,EACjC,YAAiC,EAAE,EACnC,gBAAwC,EACxC,gBAA0C;QAE1C,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACjB,IAAI,CAAC,SAAS,GAAG,SAAS,CAAC;QAC3B,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;QACzC,IAAI,CAAC,gBAAgB,GAAG,gBAAgB,CAAC;IAC3C,CAAC;IAED;;;;;OAKG;IACH,KAAK,CACH,IAOwB;QAExB,IAAI,OAAO,IAAI,KAAK,QAAQ,IAAI,WAAW,CAAC,MAAM,CAAC,IAAI,CAAC,EAAE;YACxD,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACd,UAAU,CAAC,OAAO,CAAC,IAAY,CAAC,CAAC;oBACjC,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;aAAM,IAAI,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE;YAC9B,IAAI,CAAC,SAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YACjC,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACb,IAAoB;yBAClB,MAAM,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,IAAI,KAAK,IAAI,CAAC;yBAC/B,OAAO,CAAC,CAAC,IAAI,EAAE,EAAE,CAAC,UAAU,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC;oBAC/C,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;aAAM,IAAI,OAAO,IAAI,KAAK,QAAQ,IAAI,CAAC,CAAC,IAAI,YAAY,cAAc,CAAC,EAAE;YACxE,IAAI,CAAC,SAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YACjC,IAAI,GAAG,IAAI,cAAc,CAAC;gBACxB,KAAK,CAAC,UAAU;oBACd,UAAU,CAAC,OAAO,CAAC,IAAY,CAAC,CAAC;oBACjC,UAAU,CAAC,KAAK,EAAE,CAAC;gBACrB,CAAC;aACF,CAAC,CAAC;SACJ;QAED,IAAI,CAAC,CAAC,IAAI,YAAY,cAAc,CAAC,EAAE;YACrC,MAAM,IAAI,KAAK,CACb,yEAAyE,CAC1E,CAAC;SACH;QAED,MAAM,SAAS,GAAG,IAAI,6BAA6B,CACjD,IAAI,CAAC,IAAI,EACT,IAAI,CAAC,SAAS,EACd,IAAI,CAAC,gBAAgB,EACrB,IAAI,CAAC,gBAAgB,CACtB,CAAC;QACF,OAAO,IAAI,CAAC,WAAW,CAAC,SAAS,CAAoC,CAAC;IACxE,CAAC;CACF"}

dist/mjs/index.d.ts

 export type { ParserOptions, StreamParserOptions } from '@json2csv/plainjs';
 export { default as AsyncParser } from './AsyncParser.js';
-export { default as TransformStream } from './TransformStream.js';
+export { default as TransformStream, type AwaitableReadableStream, } from './TransformStream.js';
 //# sourceMappingURL=index.d.ts.map

dist/mjs/index.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA,YAAY,EAAE,aAAa,EAAE,mBAAmB,EAAE,MAAM,mBAAmB,CAAC;AAC5E,OAAO,EAAE,OAAO,IAAI,WAAW,EAAE,MAAM,kBAAkB,CAAC;AAC1D,OAAO,EAAE,OAAO,IAAI,eAAe,EAAE,MAAM,sBAAsB,CAAC"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AAAA,YAAY,EAAE,aAAa,EAAE,mBAAmB,EAAE,MAAM,mBAAmB,CAAC;AAC5E,OAAO,EAAE,OAAO,IAAI,WAAW,EAAE,MAAM,kBAAkB,CAAC;AAC1D,OAAO,EACL,OAAO,IAAI,eAAe,EAC1B,KAAK,uBAAuB,GAC7B,MAAM,sBAAsB,CAAC"}

dist/mjs/index.js

 export { default as AsyncParser } from './AsyncParser.js';
-export { default as TransformStream } from './TransformStream.js';
+export { default as TransformStream, } from './TransformStream.js';
 //# sourceMappingURL=index.js.map

dist/mjs/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,OAAO,IAAI,WAAW,EAAE,MAAM,kBAAkB,CAAC;AAC1D,OAAO,EAAE,OAAO,IAAI,eAAe,EAAE,MAAM,sBAAsB,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../../src/index.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,OAAO,IAAI,WAAW,EAAE,MAAM,kBAAkB,CAAC;AAC1D,OAAO,EACL,OAAO,IAAI,eAAe,GAE3B,MAAM,sBAAsB,CAAC"}

dist/mjs/TransformStream.d.ts

 import { type ParserOptions, type StreamParserOptions } from '@json2csv/plainjs';
-interface AwaitableReadableStream<T> extends ReadableStream<T> {
+export interface AwaitableReadableStream<T> extends ReadableStream<T> {
     promise(): Promise<string>;
@@ -13,3 +13,2 @@ }
 }
-export {};
 //# sourceMappingURL=TransformStream.d.ts.map

dist/mjs/TransformStream.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"TransformStream.d.ts","sourceRoot":"","sources":["../../src/TransformStream.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,KAAK,aAAa,EAElB,KAAK,mBAAmB,EACzB,MAAM,mBAAmB,CAAC;AAwC3B,UAAU,uBAAuB,CAAC,CAAC,CAAE,SAAQ,cAAc,CAAC,CAAC,CAAC;IAC5D,OAAO,IAAI,OAAO,CAAC,MAAM,CAAC,CAAC;CAC5B;AAED,MAAM,CAAC,OAAO,OAAO,6BAA6B,CAC9C,IAAI,SAAS,MAAM,EACnB,CAAC,SAAS,MAAM,CAElB,SAAQ,eAAe,CAAC,IAAI,EAAE,MAAM,CACpC,YAAW,eAAe,CAAC,IAAI,EAAE,MAAM,CAAC,EAAE,WAAW;IAErD,SAAkB,QAAQ,EAAG,uBAAuB,CAAC,MAAM,CAAC,CAAC;IAC7D,OAAO,CAAC,QAAQ,CAAC,CAAmB;gBAGlC,IAAI,GAAE,aAAa,CAAC,IAAI,EAAE,CAAC,CAAM,EACjC,SAAS,GAAE,mBAAwB,EACnC,gBAAgB,CAAC,EAAE,eAAe,CAAC,IAAI,CAAC,EACxC,gBAAgB,CAAC,EAAE,eAAe,CAAC,MAAM,CAAC;IAiCrC,gBAAgB,CACrB,IAAI,EAAE,MAAM,EACZ,QAAQ,EAAE,kCAAkC,GAAG,IAAI,EACnD,OAAO,CAAC,EAAE,OAAO,GAAG,uBAAuB,GAAG,SAAS,GACtD,IAAI;IAIA,aAAa,CAAC,KAAK,EAAE,KAAK,GAAG,OAAO;IAIpC,mBAAmB,CACxB,IAAI,EAAE,MAAM,EACZ,QAAQ,EAAE,kCAAkC,GAAG,IAAI,EACnD,OAAO,CAAC,EAAE,OAAO,GAAG,oBAAoB,GAAG,SAAS,GACnD,IAAI;CAGR"}
+{"version":3,"file":"TransformStream.d.ts","sourceRoot":"","sources":["../../src/TransformStream.ts"],"names":[],"mappings":"AAAA,OAAO,EACL,KAAK,aAAa,EAElB,KAAK,mBAAmB,EACzB,MAAM,mBAAmB,CAAC;AAwC3B,MAAM,WAAW,uBAAuB,CAAC,CAAC,CAAE,SAAQ,cAAc,CAAC,CAAC,CAAC;IACnE,OAAO,IAAI,OAAO,CAAC,MAAM,CAAC,CAAC;CAC5B;AAED,MAAM,CAAC,OAAO,OAAO,6BAA6B,CAC9C,IAAI,SAAS,MAAM,EACnB,CAAC,SAAS,MAAM,CAElB,SAAQ,eAAe,CAAC,IAAI,EAAE,MAAM,CACpC,YAAW,eAAe,CAAC,IAAI,EAAE,MAAM,CAAC,EAAE,WAAW;IAErD,SAAkB,QAAQ,EAAG,uBAAuB,CAAC,MAAM,CAAC,CAAC;IAC7D,OAAO,CAAC,QAAQ,CAAC,CAAmB;gBAGlC,IAAI,GAAE,aAAa,CAAC,IAAI,EAAE,CAAC,CAAM,EACjC,SAAS,GAAE,mBAAwB,EACnC,gBAAgB,CAAC,EAAE,eAAe,CAAC,IAAI,CAAC,EACxC,gBAAgB,CAAC,EAAE,eAAe,CAAC,MAAM,CAAC;IAiCrC,gBAAgB,CACrB,IAAI,EAAE,MAAM,EACZ,QAAQ,EAAE,kCAAkC,GAAG,IAAI,EACnD,OAAO,CAAC,EAAE,OAAO,GAAG,uBAAuB,GAAG,SAAS,GACtD,IAAI;IAIA,aAAa,CAAC,KAAK,EAAE,KAAK,GAAG,OAAO;IAIpC,mBAAmB,CACxB,IAAI,EAAE,MAAM,EACZ,QAAQ,EAAE,kCAAkC,GAAG,IAAI,EACnD,OAAO,CAAC,EAAE,OAAO,GAAG,oBAAoB,GAAG,SAAS,GACnD,IAAI;CAGR"}

package.json

 {
   "name": "@json2csv/whatwg",
-  "version": "7.0.4",
+  "version": "7.0.5",
   "description": "WHATWG Transform and Async interface to convert JSON into CSV.",
@@ -46,3 +46,3 @@ "keywords": [
     "test-with-coverage": "c8 --reporter=text npm test",
-    "test:raw": "ts-node --esm test/index.ts",
+    "test:raw": "node --loader ts-node/esm test/index.ts",
     "dependencies:update-internal": "npm uninstall @json2csv/plainjs && npm install @json2csv/plainjs",
@@ -52,4 +52,4 @@ "prepublishOnly": "npm run build"
   "dependencies": {
-    "@json2csv/plainjs": "^7.0.4"
+    "@json2csv/plainjs": "^7.0.5"
   }
 }

README.md

@@ -175,3 +175,3 @@ # @json2csv/whatwg
 ```js
-import { TransformStream } from '@json2csv/whatwg';
+import { AsyncParser } from '@json2csv/whatwg';
 
@@ -182,3 +182,3 @@ const opts = {};
 const readableStrategy = {};
-const parser = new TransformStream(opts, asyncOpts, writableStrategy, readableStrategy);
+const parser = new AsyncParser(opts, asyncOpts, writableStrategy, readableStrategy);
 
@@ -192,7 +192,2 @@ const response = await fetch('./my-file.json');
 parser.parse(data).pipeTo(writableStream);
-
-// You can also listen for events on the conversion and see how the header or the lines are coming out.
-parser
-  .addEventListener('header', (header) => console.log(header))
-  .addEventListener('line', (line) => console.log(line));
 ```
@@ -199,0 +194,0 @@

src/AsyncParser.ts

 import type { ParserOptions, StreamParserOptions } from '@json2csv/plainjs';
-import JSON2CSVWHATWGTransformStream from './TransformStream.js';
+import JSON2CSVWHATWGTransformStream, {
+  type AwaitableReadableStream,
+} from './TransformStream.js';
 
@@ -39,3 +41,3 @@ export default class JSON2CSVNodeAsyncParser<
       | ReadableStream<TRaw>,
-  ) {
+  ): AwaitableReadableStream<string> {
     if (typeof data === 'string' || ArrayBuffer.isView(data)) {
@@ -80,4 +82,4 @@ data = new ReadableStream({
     );
-    return data.pipeThrough(transform);
+    return data.pipeThrough(transform) as AwaitableReadableStream<string>;
   }
 }

src/index.ts

 export type { ParserOptions, StreamParserOptions } from '@json2csv/plainjs';
 export { default as AsyncParser } from './AsyncParser.js';
-export { default as TransformStream } from './TransformStream.js';
+export {
+  default as TransformStream,
+  type AwaitableReadableStream,
+} from './TransformStream.js';

src/TransformStream.ts

@@ -45,3 +45,3 @@ import {
 
-interface AwaitableReadableStream<T> extends ReadableStream<T> {
+export interface AwaitableReadableStream<T> extends ReadableStream<T> {
   promise(): Promise<string>;
@@ -48,0 +48,0 @@ }

No alert changes

Improved metrics

Lines of code

514

0.98%

Worsened metrics

Total package byte prevSize

127610

-1.5%

Number of lines in readme file

240

-2.04%

Dependency changes

• Updated

  @json2csv/plainjs@^7.0.5