diff --git a/src/components/P2P/index.ts b/src/components/P2P/index.ts
index dbc9808e1..5c794a39d 100644
--- 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