redis/go-redis
1
0
Fork 0
mirror of https://github.com/redis/go-redis.git synced 2025-10-20 09:52:25 +03:00
Code Activity

Added batch process method to the pipeline (#3510)

Browse Source 
* Added batch process method to the pipeline

* Added Process and BatchProcess tests

* Fix test matching
This commit is contained in:
Hristo Temelski
2025-09-09 18:10:17 +03:00
committed by GitHub
parent 65e1c22065
commit e0853aba63
2 changed files with 29 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
pipeline_test.go
View File

@@ -114,6 +114,25 @@ var _ = Describe("pipelining", func() {
err := pipe.Do(ctx).Err()
Expect(err).To(Equal(errors.New("redis: please enter the command to be executed")))
})
It("should process", func() {
err := pipe.Process(ctx, redis.NewCmd(ctx, "asking"))
Expect(err).To(BeNil())
Expect(pipe.Cmds()).To(HaveLen(1))
})
It("should batchProcess", func() {
err := pipe.BatchProcess(ctx, redis.NewCmd(ctx, "asking"))
Expect(err).To(BeNil())
Expect(pipe.Cmds()).To(HaveLen(1))
pipe.Discard()
Expect(pipe.Cmds()).To(HaveLen(0))
err = pipe.BatchProcess(ctx, redis.NewCmd(ctx, "asking"), redis.NewCmd(ctx, "set", "key", "value"))
Expect(err).To(BeNil())
Expect(pipe.Cmds()).To(HaveLen(2))
})
}
Describe("Pipeline", func() {