Fix #83

diff --git a/Reply/F.go b/Reply/F.go
index 27282f8d089b55cfd4cd5bd70868da4a0e8c30cc..d459d8c7a243bbbd985afcf877f68ab039b51255 100644 (file)
--- 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 d196cab9006390ffcf26e9f827db693a4d89fb6f..ffbc9941c7cfaaa5bc03d3afaec4a48910ee8c16 100644 (file)
--- 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 {