mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

test: Disable tests for cancelled context

This commit is contained in:
Adam Snyder 2023-02-09 12:10:16 -08:00
parent 2add8bd7c5
commit 4d4a65774c
3 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
commands_test.go
View File

@ -4843,7 +4843,8 @@ var _ = Describe("Commands", func() {
Expect(err).To(Equal(redis.Nil)) Expect(err).To(Equal(redis.Nil))
}) })
Describe("canceled context", func() { // https://github.com/redis/go-redis/issues/2276
PDescribe("canceled context", func() {
It("should unblock XRead", func() { It("should unblock XRead", func() {
ctx2, cancel := context.WithCancel(ctx) ctx2, cancel := context.WithCancel(ctx)
errCh := make(chan error, 1) errCh := make(chan error, 1)
@ -5042,7 +5043,8 @@ var _ = Describe("Commands", func() {
Expect(n).To(Equal(int64(2))) Expect(n).To(Equal(int64(2)))
}) })
Describe("canceled context", func() { // https://github.com/redis/go-redis/issues/2276
PDescribe("canceled context", func() {
It("should unblock XReadGroup", func() { It("should unblock XReadGroup", func() {
ctx2, cancel := context.WithCancel(ctx) ctx2, cancel := context.WithCancel(ctx)
errCh := make(chan error, 1) errCh := make(chan error, 1)

3
internal_test.go
View File

@ -352,7 +352,8 @@ var _ = Describe("withConn", func() {
Expect(client.connPool.Len()).To(Equal(1)) Expect(client.connPool.Len()).To(Equal(1))
}) })
It("should remove the connection from the pool if the context is canceled", func() { // https://github.com/redis/go-redis/issues/2276
PIt("should remove the connection from the pool if the context is canceled", func() {
var conn *pool.Conn var conn *pool.Conn
ctx2, cancel := context.WithCancel(ctx) ctx2, cancel := context.WithCancel(ctx)

3
pubsub_test.go
View File

@ -569,7 +569,8 @@ var _ = Describe("PubSub", func() {
Expect(msg.Payload).To(Equal(text)) Expect(msg.Payload).To(Equal(text))
}) })
Describe("canceled context", func() { // https://github.com/redis/go-redis/issues/2276
PDescribe("canceled context", func() {
It("should unblock ReceiveMessage", func() { It("should unblock ReceiveMessage", func() {
pubsub := client.Subscribe(ctx, "mychannel") pubsub := client.Subscribe(ctx, "mychannel")
defer pubsub.Close() defer pubsub.Close()