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 bdeda87 commit 74164a4Copy full SHA for 74164a4
pubsub_test.go
@@ -113,6 +113,9 @@ var _ = Describe("PubSub", func() {
113
pubsub := client.SSubscribe(ctx, "mychannel", "mychannel2")
114
defer pubsub.Close()
115
116
+ // sleep a bit to make sure redis knows about the subscriptions
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