From 413ba12f50cbb08280973fc83e5c265586ca6608 Mon Sep 17 00:00:00 2001
From: yukun <kun.yu@zilliz.com>
Date: Fri, 1 Oct 2021 20:53:41 +0800
Subject: [PATCH] [skip ci]Format message stream doc (#9021)

Signed-off-by: fishpenguin <kun.yu@zilliz.com>
---
 .../developer_guides/chap04_message_stream.md | 24 +++++++++----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/docs/developer_guides/chap04_message_stream.md b/docs/developer_guides/chap04_message_stream.md
index 0807ca9c6b..65a327a1c6 100644
--- a/docs/developer_guides/chap04_message_stream.md
+++ b/docs/developer_guides/chap04_message_stream.md
@@ -247,19 +247,19 @@ func (rmsf *RmqMsgStreamFactory) NewTtMsgStream() *MsgStream
 // PulsarMsgStream
 
 type PulsarMsgStream struct {
-	ctx							context.Context
-	client					 pulsar.Client
-	producers				[]Producer
-	consumers				[]Consumer
-	consumerChannels []string
-	repackFunc			 RepackFunc
-	unmarshal				UnmarshalDispatcher
-	receiveBuf			 chan *MsgPack
-	wait						 *sync.WaitGroup
-	streamCancel		 func()
+	ctx					context.Context
+	client				pulsar.Client
+	producers			[]Producer
+	consumers			[]Consumer
+	consumerChannels 	[]string
+	repackFunc			RepackFunc
+	unmarshal			UnmarshalDispatcher
+	receiveBuf			chan *MsgPack
+	wait				*sync.WaitGroup
+	streamCancel		func()
 	pulsarBufSize		int64
-	consumerLock		 *sync.Mutex
-	consumerReflects []reflect.SelectCase
+	consumerLock		*sync.Mutex
+	consumerReflects 	[]reflect.SelectCase
 	
 	scMap *sync.Map
 }