*Wrap handleBuffer in filterPromise/streamPromise chain to ensure it is called when the stream is ready

*Use an empty uint8array on reduce to handle edge cases

src/contentProviders/ipfsProvider.ts

@@ -282,6 +282,8 @@ export default class IpfsProvider extends BaseProvider {
 
     const handleBuffer = () => {
       if (buffer.length) {
+        filterPromise.then(() => {
+          streamPromise = streamPromise.then(() => {
             let mode = contentModes[contentType as string];
             buffer = buffer.map((item: Uint8Array | ArrayBuffer) => {
               if (item instanceof ArrayBuffer) {
@@ -294,30 +296,16 @@ export default class IpfsProvider extends BaseProvider {
                 buffer.reduce(
                   (previousValue: Uint8Array, currentValue: Uint8Array) => {
                     return Uint8Array.from([...previousValue, ...currentValue]);
-              }
+                  },
+                  new Uint8Array()
                 )
               );
-          /*            if (contentType === "text/html") {
-                  data = new TextDecoder("utf-8", { fatal: true }).decode(data);
-                  let htmlDoc = new DOMParser().parseFromString(
-                    data as string,
-                    contentType
-                  );
-                  let found = htmlDoc.documentElement.querySelectorAll(
-                    'meta[http-equiv="Content-Security-Policy"]'
-                  );
-
-                  if (found.length) {
-                    found.forEach((item) => item.remove());
-                    data = htmlDoc.documentElement.outerHTML;
-                  }
-
-                  data = new TextEncoder().encode(data);
-                }*/
               filter.write(data);
             } else if (mode == CONTENT_MODE_CHUNKED) {
               buffer.forEach((data) => filter.write(data));
             }
+          });
+        });
       }
     };
     if (cachedPage) {
@@ -345,7 +333,8 @@ export default class IpfsProvider extends BaseProvider {
             (cacheBuffer as Uint8Array[]).reduce(
               (previousValue: Uint8Array, currentValue: Uint8Array) => {
                 return Uint8Array.from([...previousValue, ...currentValue]);
-              }
+              },
+              new Uint8Array()
             )
           );