From 98339fa6579c1f4f7639df6c2b289ad7a959978d Mon Sep 17 00:00:00 2001
From: "lin.huang" <lin.huang@apulis.com>
Date: Fri, 22 Dec 2023 19:28:31 +0800
Subject: [PATCH] fix:fix go routine values error

---
 internal/push/push_to_client.go | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/internal/push/push_to_client.go b/internal/push/push_to_client.go
index 506030053..1ee6e3f6c 100644
--- a/internal/push/push_to_client.go
+++ b/internal/push/push_to_client.go
@@ -361,9 +361,11 @@ func (p *Pusher) k8sOnlinePush(ctx context.Context, msg *sdkws.MsgData, pushToUs
 	}
 	wg.SetLimit(maxWorkers)
 	for conn, userIds := range usersConns {
+		tcon := conn
+		tuserIds := userIds
 		wg.Go(func() error {
-			input := &msggateway.OnlineBatchPushOneMsgReq{MsgData: msg, PushToUserIDs: userIds}
-			msgClient := msggateway.NewMsgGatewayClient(conn)
+			input := &msggateway.OnlineBatchPushOneMsgReq{MsgData: msg, PushToUserIDs: tuserIds}
+			msgClient := msggateway.NewMsgGatewayClient(tcon)
 			reply, err := msgClient.SuperGroupOnlineBatchPushOneMsg(ctx, input)
 			if err != nil {
 				return nil