From 97636c4c7adc9d07871f8eb9ac9a402a043a1d38 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Thu, 4 Jul 2024 10:51:26 +0800 Subject: [PATCH] test --- pkg/common/storage/cache/redis/seq_user_test.go | 3 --- 1 file changed, 3 deletions(-) diff --git a/pkg/common/storage/cache/redis/seq_user_test.go b/pkg/common/storage/cache/redis/seq_user_test.go index cfbea004c..e4fd95922 100644 --- a/pkg/common/storage/cache/redis/seq_user_test.go +++ b/pkg/common/storage/cache/redis/seq_user_test.go @@ -66,16 +66,13 @@ func TestRecvOnline(t *testing.T) { ctx := context.Background() pubsub := ts.rdb.Subscribe(ctx, cachekey.OnlineChannel) - // 等待订阅确认 _, err := pubsub.Receive(ctx) if err != nil { log.Fatalf("Could not subscribe: %v", err) } - // 创建一个通道来接收消息 ch := pubsub.Channel() - // 处理接收到的消息 for msg := range ch { fmt.Printf("Received message from channel %s: %s\n", msg.Channel, msg.Payload) }