From a3b300bd1d49463450218698cf88d04d5f3a6015 Mon Sep 17 00:00:00 2001
From: kaven <zzulikang@gmail.com>
Date: Thu, 4 Jul 2024 11:39:48 +0800
Subject: [PATCH] Fixing Streamed Output Misalignment

---
 metagpt/utils/stream_pipe.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/metagpt/utils/stream_pipe.py b/metagpt/utils/stream_pipe.py
index 4c4485158..1cccda7ee 100644
--- a/metagpt/utils/stream_pipe.py
+++ b/metagpt/utils/stream_pipe.py
@@ -11,8 +11,10 @@ from multiprocessing import Pipe
 
 
 class StreamPipe:
-    parent_conn, child_conn = Pipe()
-    finish: bool = False
+    def __init__(self,name=None):
+        self.name = name
+        self.parent_conn, self.child_conn = Pipe()
+        self.finish: bool = False
 
     format_data = {
         "id": "chatcmpl-96bVnBOOyPFZZxEoTIGbdpFcVEnur",