From 02eea8f5dea6d365cd3d791b8ab5ff605bff4bb6 Mon Sep 17 00:00:00 2001
From: qydysky <32743305+qydysky@users.noreply.github.com>
Date: Sat, 28 Jan 2023 00:43:49 +0800
Subject: [PATCH] =?utf8?q?Fix=20=E9=81=BF=E5=85=8D=E7=9F=AD=E6=97=B6?=
 =?utf8?q?=E9=97=B4=E9=87=8D=E5=A4=8D=E5=BC=80=E6=92=AD=E5=AF=BC=E8=87=B4?=
 =?utf8?q?=E7=9A=84=E9=87=8D=E5=A4=8D=E5=BD=95=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 Reply/stream.go | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/Reply/stream.go b/Reply/stream.go
index a18ca68..ef9dc91 100644
--- a/Reply/stream.go
+++ b/Reply/stream.go
@@ -1042,16 +1042,18 @@ func (t *M4SStream) Start() bool {
 		return false
 	}
 
+	// 实例回调
+	if t.Callback_start != nil {
+		if e := t.Callback_start(t); e != nil {
+			t.log.L(`W: `, `开始回调错误`, e.Error())
+			return false
+		}
+	}
+
 	t.Status = signal.Init()
 	go func() {
 		defer t.Status.Done()
 
-		// 实例回调
-		if t.Callback_start != nil {
-			if e := t.Callback_start(t); e != nil {
-				t.log.L(`W: `, `开始回调错误`, e.Error())
-			}
-		}
 		if t.Callback_stop != nil {
 			defer t.Callback_stop(t)
 		}
-- 
2.39.2