From 87de5aa6cf681a4d372d44fddbb855c6ae441669 Mon Sep 17 00:00:00 2001
From: yukun <kun.yu@zilliz.com>
Date: Mon, 4 Oct 2021 13:39:57 +0800
Subject: [PATCH] [skip ci]Remove PulsarMsgStream in docs (#9201)

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

diff --git a/docs/developer_guides/chap04_message_stream.md b/docs/developer_guides/chap04_message_stream.md
index 60afd40252..0d9c65cb73 100644
--- a/docs/developer_guides/chap04_message_stream.md
+++ b/docs/developer_guides/chap04_message_stream.md
@@ -253,35 +253,7 @@ type RmsFactory struct {
 ```go
 // 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()
-	pulsarBufSize		int64
-	consumerLock		*sync.Mutex
-	consumerReflects 	[]reflect.SelectCase
-	
-	scMap *sync.Map
-}
-
-func (ms *PulsarMsgStream) Start() error
-func (ms *PulsarMsgStream) Close() error
-func (ms *PulsarMsgStream) AsProducer(channels []string)
-func (ms *PulsarMsgStream) AsConsumer(channels []string, subName string)
-func (ms *PulsarMsgStream) Produce(ctx context.Context, msgs *MsgPack) error
-func (ms *PulsarMsgStream) Broadcast(ctx context.Context, msgs *MsgPack) error
-func (ms *PulsarMsgStream) Consume() (*MsgPack, context.Context)
-func (ms *PulsarMsgStream) Seek(mp *MsgPosition) error
-func (ms *PulsarMsgStream) SetRepackFunc(repackFunc RepackFunc)
-
-func NewPulsarMsgStream(ctx context.Context, pulsarAddr string, bufferSize int64) *PulsarMsgStream
+func (f *PmsFactory) NewMsgStream(ctx context.Context) (MsgStream, error)
 
 
 type PulsarTtMsgStream struct {