transform merged stream

bitpay · May 22, 2024 · e0577ec · e0577ec
1 parent 898d964
commit e0577ec
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/packages/bitcore-node/src/providers/chain-state/external/streams/apiStream.ts b/packages/bitcore-node/src/providers/chain-state/external/streams/apiStream.ts
@@ -1,6 +1,6 @@
 import axios from 'axios';
 import { Request, Response } from 'express';
-import { Readable, Stream, Writable } from 'stream';
+import { Readable, Stream, Transform, Writable } from 'stream';
 
 export class ExternalApiStream extends Readable {
   url: string;
@@ -145,4 +145,14 @@ export class ExternalApiStream extends Readable {
       });
     };
   }
+}
+
+export class MergedStream extends Transform {
+  constructor() {
+    super({ objectMode: true });
+  }
+
+  async _transform(data: any, _, done) {
+    done(null, data);
+  }
 }