forked from mirror/redis
commit
a40c8d17fe
|
@ -6,10 +6,10 @@ import (
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"gopkg.in/redis.v5"
|
||||||
|
|
||||||
. "github.com/onsi/ginkgo"
|
. "github.com/onsi/ginkgo"
|
||||||
. "github.com/onsi/gomega"
|
. "github.com/onsi/gomega"
|
||||||
|
|
||||||
"gopkg.in/redis.v5"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var _ = Describe("PubSub", func() {
|
var _ = Describe("PubSub", func() {
|
||||||
|
@ -348,10 +348,13 @@ var _ = Describe("PubSub", func() {
|
||||||
|
|
||||||
wg.Done()
|
wg.Done()
|
||||||
defer wg.Done()
|
defer wg.Done()
|
||||||
|
|
||||||
_, err := pubsub.ReceiveMessage()
|
|
||||||
Expect(err).To(MatchError("redis: client is closed"))
|
|
||||||
|
|
||||||
|
_, err := pubsub.ReceiveMessage()
|
||||||
|
Expect(err).To(HaveOccurred())
|
||||||
|
Expect(err).To(SatisfyAny(
|
||||||
|
MatchError("redis: client is closed"),
|
||||||
|
MatchError("use of closed network connection"), // Go 1.4
|
||||||
|
))
|
||||||
}()
|
}()
|
||||||
|
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
|
|
Loading…
Reference in New Issue