From 8c21ec00067496e12ca2b6f1b08779662b242835 Mon Sep 17 00:00:00 2001 From: Yuval Pavel Zholkover Date: Fri, 21 Apr 2017 15:50:26 +0300 Subject: [PATCH] Fix typo in ClusterClient.TxPipelined() It should be using ClusterClient.TxPipeline() and not ClusterClient.Pipeline(). --- cluster.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cluster.go b/cluster.go index 9bc65065..223d2522 100644 --- a/cluster.go +++ b/cluster.go @@ -807,7 +807,7 @@ func (c *ClusterClient) TxPipeline() *Pipeline { } func (c *ClusterClient) TxPipelined(fn func(*Pipeline) error) ([]Cmder, error) { - return c.Pipeline().pipelined(fn) + return c.TxPipeline().pipelined(fn) } func (c *ClusterClient) txPipelineExec(cmds []Cmder) error {