forked from mirror/redis
Increase timeout
This commit is contained in:
parent
29e07c1098
commit
f18a97fc94
|
@ -69,7 +69,7 @@ var _ = Describe("Sentinel", func() {
|
||||||
Expect(err).NotTo(HaveOccurred())
|
Expect(err).NotTo(HaveOccurred())
|
||||||
|
|
||||||
var msg *redis.Message
|
var msg *redis.Message
|
||||||
Eventually(ch).Should(Receive(&msg))
|
Eventually(ch, "5s").Should(Receive(&msg))
|
||||||
Expect(msg.Channel).To(Equal("foo"))
|
Expect(msg.Channel).To(Equal("foo"))
|
||||||
Expect(msg.Payload).To(Equal("hello"))
|
Expect(msg.Payload).To(Equal("hello"))
|
||||||
})
|
})
|
||||||
|
|
Loading…
Reference in New Issue