fix node crash on stream, node internals

oceanprotocol · Aug 1, 2024 · 763dcec · 763dcec
1 parent 40b86b8
commit 763dcec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/components/P2P/index.ts b/src/components/P2P/index.ts
@@ -563,7 +563,7 @@ export class OceanP2P extends EventEmitter {
     if (stream) {
       response.stream = stream
       try {
-        pipe(
+        await pipe(
           // Source data
           [uint8ArrayFromString(message)],
           // Write to the stream, and pass its output to the next function