From 4615ca2472488951adadc2af768ea6341c3da51a Mon Sep 17 00:00:00 2001
From: dexter <178529795@qq.com>
Date: Thu, 2 Feb 2023 18:01:06 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DMessageStreamID=E6=B2=A1?=
 =?UTF-8?q?=E6=9C=89=E8=B5=8B=E5=80=BC=E5=AF=BC=E8=87=B4=E7=9A=84push?=
 =?UTF-8?q?=E9=94=99=E8=AF=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 client.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/client.go b/client.go
index 46d13f2..7e0812e 100644
--- a/client.go
+++ b/client.go
@@ -121,6 +121,8 @@ func (pusher *RTMPPusher) Push() error {
 			case Response_Result, Response_OnStatus:
 				if response, ok := msg.MsgData.(*ResponseCreateStreamMessage); ok {
 					pusher.StreamID = response.StreamId
+					pusher.audio.MessageStreamID = pusher.StreamID
+					pusher.video.MessageStreamID = pusher.StreamID
 					URL, _ := url.Parse(pusher.RemoteURL)
 					_, streamPath, _ := strings.Cut(URL.Path, "/")
 					_, streamPath, _ = strings.Cut(streamPath, "/")