From c28459004edc8bd448c63f7d917678e0852e5acf Mon Sep 17 00:00:00 2001 From: qydysky Date: Sun, 6 Aug 2023 20:43:24 +0800 Subject: [PATCH] Fix #83 --- Reply/F.go | 2 +- Reply/stream.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/Reply/F.go b/Reply/F.go index 27282f8..d459d8c 100644 --- a/Reply/F.go +++ b/Reply/F.go @@ -361,7 +361,7 @@ func StreamOCut(roomid int, title ...string) { if len(title) != 0 { v.(*M4SStream).common.Title = title[0] } - v.(*M4SStream).msg.PushLock_tag(`cut`, v.(*M4SStream)) + v.(*M4SStream).msg.Push_tag(`cut`, v.(*M4SStream)) flog.L(`I: `, `已切片 `+strconv.Itoa(roomid)) } } diff --git a/Reply/stream.go b/Reply/stream.go index d196cab..ffbc994 100644 --- a/Reply/stream.go +++ b/Reply/stream.go @@ -1173,7 +1173,7 @@ func (t *M4SStream) Start() bool { } // 实例回调 - t.msg = msgq.NewType[*M4SStream]() + t.msg = msgq.NewType[*M4SStream](time.Second * 5) t.msg.Push_tag(`start`, t) if t.Callback_start != nil { if e := t.Callback_start(t); e != nil { -- 2.39.2