From 6a038643d6ab0ea3d863f09727f304f822d68cc2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=BA=90=E6=96=87=E9=9B=A8?= <41315874+fumiama@users.noreply.github.com> Date: Sun, 13 Oct 2024 16:35:51 +0900 Subject: [PATCH] feat(manager): no forward on single slow --- plugin/manager/slow.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/plugin/manager/slow.go b/plugin/manager/slow.go index 691422d550..d926d8a5ed 100644 --- a/plugin/manager/slow.go +++ b/plugin/manager/slow.go @@ -20,6 +20,10 @@ func collectsend(ctx *zero.Ctx, msgs ...message.MessageSegment) { lazy, _ := slowsenders.LoadOrStore(id, &syncx.Lazy[*slowdo.Job[*zero.Ctx, message.MessageSegment]]{ Init: func() *slowdo.Job[*zero.Ctx, message.MessageSegment] { x, err := slowdo.NewJob(time.Second*5, ctx, func(ctx *zero.Ctx, msg []message.MessageSegment) { + if len(msg) == 1 { + ctx.Send(msg) + return + } m := make(message.Message, len(msg)) for i, item := range msg { m[i] = message.CustomNode(