forked from mirror/redis
Merge branch 'master' of github.com:go-redis/redis
This commit is contained in:
commit
d371792f33
|
@ -71,7 +71,7 @@ var _ = Describe("pipelining", func() {
|
||||||
|
|
||||||
Describe("TxPipeline", func() {
|
Describe("TxPipeline", func() {
|
||||||
BeforeEach(func() {
|
BeforeEach(func() {
|
||||||
pipe = client.TxPipeline()
|
pipe = client.TxPipeline().(*redis.Pipeline)
|
||||||
})
|
})
|
||||||
|
|
||||||
assertPipeline()
|
assertPipeline()
|
||||||
|
|
2
redis.go
2
redis.go
|
@ -342,7 +342,7 @@ func (c *Client) TxPipelined(fn func(Pipeliner) error) ([]Cmder, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// TxPipeline acts like Pipeline, but wraps queued commands with MULTI/EXEC.
|
// TxPipeline acts like Pipeline, but wraps queued commands with MULTI/EXEC.
|
||||||
func (c *Client) TxPipeline() *Pipeline {
|
func (c *Client) TxPipeline() Pipeliner {
|
||||||
pipe := Pipeline{
|
pipe := Pipeline{
|
||||||
exec: c.pipelineExecer(c.txPipelineProcessCmds),
|
exec: c.pipelineExecer(c.txPipelineProcessCmds),
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue