We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e91f6ce commit 6b9cbe8Copy full SHA for 6b9cbe8
pubsub_test.go
@@ -113,6 +113,9 @@ var _ = Describe("PubSub", func() {
113
pubsub := client.SSubscribe(ctx, "mychannel", "mychannel2")
114
defer pubsub.Close()
115
116
+ // Let Redis process the ssubscribe command.
117
+ time.Sleep(10 * time.Millisecond)
118
+
119
channels, err = client.PubSubShardChannels(ctx, "mychannel*").Result()
120
Expect(err).NotTo(HaveOccurred())
121
Expect(channels).To(ConsistOf([]string{"mychannel", "mychannel2"}))
0 commit comments