feat(manager): no forward on single slow

FloatTech · Oct 13, 2024 · 6a03864 · 6a03864
1 parent 339b9db
commit 6a03864
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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(