diff --git a/commands_test.go b/commands_test.go index 24602e14..82e1a092 100644 --- a/commands_test.go +++ b/commands_test.go @@ -33,9 +33,10 @@ var _ = Describe("Commands", func() { pipe.Auth("") return nil }) - Expect(err).To(MatchError("ERR Client sent AUTH, but no password is set")) - Expect(cmds[0].Err()).To(MatchError("ERR Client sent AUTH, but no password is set")) - Expect(cmds[1].Err()).To(MatchError("ERR Client sent AUTH, but no password is set")) + Expect(err).To(HaveOccurred()) + Expect(err.Error()).To(ContainSubstring("ERR AUTH")) + Expect(cmds[0].Err().Error()).To(ContainSubstring("ERR AUTH")) + Expect(cmds[1].Err().Error()).To(ContainSubstring("ERR AUTH")) stats := client.PoolStats() Expect(stats.Hits).To(Equal(uint32(1))) diff --git a/race_test.go b/race_test.go index 9a575555..f4b11778 100644 --- a/race_test.go +++ b/race_test.go @@ -261,13 +261,17 @@ var _ = Describe("races", func() { Expect(n).To(Equal(int64(N))) }) - It("should BLPop", func() { + PIt("should BLPop", func() { var received uint32 + wg := performAsync(C, func(id int) { for { v, err := client.BLPop(3*time.Second, "list").Result() if err != nil { - break + if err == redis.Nil { + break + } + Expect(err).NotTo(HaveOccurred()) } Expect(v).To(Equal([]string{"list", "hello"})) atomic.AddUint32(&received, 1) @@ -282,7 +286,7 @@ var _ = Describe("races", func() { }) wg.Wait() - Expect(received).To(Equal(uint32(C * N))) + Expect(atomic.LoadUint32(&received)).To(Equal(uint32(C * N))) }) It("should WithContext", func() { diff --git a/ring_test.go b/ring_test.go index e2ea9912..0ea03604 100644 --- a/ring_test.go +++ b/ring_test.go @@ -206,7 +206,8 @@ var _ = Describe("Redis Ring", func() { ring = redis.NewRing(opts) err := ring.Ping().Err() - Expect(err).To(MatchError("ERR Client sent AUTH, but no password is set")) + Expect(err).To(HaveOccurred()) + Expect(err.Error()).To(ContainSubstring("ERR AUTH")) }) })