replace internal TextDecoder with TextDecoderStream pipe

Author: dbushell

deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@dbushell/xml-streamify",
-  "version": "0.4.0",
+  "version": "0.5.0",
   "exports": {
     ".": "./mod.ts",
     "./node": "./src/node.ts",

src/parse.ts

@@ -38,9 +38,11 @@ export async function* parse(
       throw new Error(`Bad response`);
     }
 
-    const stream = response.body.pipeThrough(new XMLStream(), {
-      signal: options?.signal
-    });
+    const stream = response.body
+      .pipeThrough(new TextDecoderStream())
+      .pipeThrough(new XMLStream(), {
+        signal: options?.signal
+      });
 
     // Set root document as current node
     let node = document;

src/stream.ts

@@ -31,24 +31,22 @@ const ENTITIES = {
 } as const;
 
 /** Transformer object for `TransformStream` constructed by `XMLStream` */
-export const transformer: Transformer<Uint8Array, [NodeType, string]> & {
+export const transformer: Transformer<string, [NodeType, string]> & {
   buf: string;
   state: State;
   previous: [State, number];
-  decoder: TextDecoder;
 } = {
   buf: '',
   state: StateType.SKIP,
   previous: [StateType.SKIP, -1],
-  decoder: new TextDecoder(),
   flush(controller) {
     // Buffer should be empty if document is well-formed
     if (this.buf.length > 0) {
       controller.enqueue([NodeType.TEXT, this.buf]);
     }
   },
   transform(chunk, controller) {
-    this.buf += this.decoder.decode(chunk);
+    this.buf += chunk;
     while (this.buf.length) {
       // Break if no progress is made (entity may straddle chunk boundary)
       if (
@@ -98,7 +96,7 @@ export const transformer: Transformer<Uint8Array, [NodeType, string]> & {
 };
 
 /** Transform a binary XML stream into a stream of structured XML data */
-export class XMLStream extends TransformStream<Uint8Array, [NodeType, string]> {
+export class XMLStream extends TransformStream<string, [NodeType, string]> {
   constructor() {
     super({...transformer});
   }