]> 127.0.0.1 Git - bili_danmu/.git/commitdiff
Fix 重复的定时器
authorqydysky <qydysky@foxmail.com>
Sat, 18 Nov 2023 04:50:05 +0000 (12:50 +0800)
committerqydysky <qydysky@foxmail.com>
Sat, 18 Nov 2023 04:50:05 +0000 (12:50 +0800)
bili_danmu.go

index d8a74e314561d1fa928feff822393418963b812c..a9fcc7d54baa9937053dc4f4d3cad83204d5cc61 100644 (file)
@@ -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 {