Skip to content

Commit 6a03864

Browse files
committed
feat(manager): no forward on single slow
1 parent 339b9db commit 6a03864

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

‎plugin/manager/slow.go‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,10 @@ func collectsend(ctx *zero.Ctx, msgs ...message.MessageSegment) {
2020
lazy, _ := slowsenders.LoadOrStore(id, &syncx.Lazy[*slowdo.Job[*zero.Ctx, message.MessageSegment]]{
2121
Init: func() *slowdo.Job[*zero.Ctx, message.MessageSegment] {
2222
x, err := slowdo.NewJob(time.Second*5, ctx, func(ctx *zero.Ctx, msg []message.MessageSegment) {
23+
if len(msg) == 1 {
24+
ctx.Send(msg)
25+
return
26+
}
2327
m := make(message.Message, len(msg))
2428
for i, item := range msg {
2529
m[i] = message.CustomNode(

0 commit comments

Comments
 (0)