From cf8e0dd2f8c3d42ccc44eb713cea4f7f673e11e4 Mon Sep 17 00:00:00 2001 From: qydysky Date: Sat, 18 Nov 2023 12:50:05 +0800 Subject: [PATCH] =?utf8?q?Fix=20=E9=87=8D=E5=A4=8D=E7=9A=84=E5=AE=9A?= =?utf8?q?=E6=97=B6=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- bili_danmu.go | 15 ++++++++------- 1 file changed, 8 insertions(+), 7 deletions(-) diff --git a/bili_danmu.go b/bili_danmu.go index d8a74e3..a9fcc7d 100644 --- a/bili_danmu.go +++ b/bili_danmu.go @@ -91,6 +91,14 @@ func Start() { // 指定房间录制区间 if err := recStartEnd.InitF.Run(context.Background(), c.C); err != nil { danmulog.Base("功能", "指定房间录制区间").L(`E: `, err) + } else { + _ = recStartEnd.LoopCheck.Run(context.Background(), recStartEnd.StreamCtl{ + C: c.C, + State: reply.StreamOStatus, + Start: reply.StreamOStart, + End: reply.StreamOStop, + Cut: func(i int) { reply.StreamOCut(i) }, + }) } //使用带tag的消息队列在功能间传递消息 @@ -290,13 +298,6 @@ func Start() { reply.Danmuji_auto() } { //附加功能 进房间发送弹幕 直播流保存 每日签到 - _ = recStartEnd.LoopCheck.Run(context.Background(), recStartEnd.StreamCtl{ - C: c.C, - State: reply.StreamOStatus, - Start: reply.StreamOStart, - End: reply.StreamOStop, - Cut: func(i int) { reply.StreamOCut(i) }, - }) go F.Dosign() go reply.Entry_danmu() if e := recStartEnd.RecStartCheck.Run(context.Background(), c.C); e == nil { -- 2.39.2