diff --git a/cluster.go b/cluster.go index c9f1384b..bdfdb83d 100644 --- a/cluster.go +++ b/cluster.go @@ -1198,6 +1198,7 @@ func (c *ClusterClient) WrapProcessPipeline( fn func(oldProcess func([]Cmder) error) func([]Cmder) error, ) { c.processPipeline = fn(c.processPipeline) + c.processTxPipeline = fn(c.processTxPipeline) } func (c *ClusterClient) defaultProcessPipeline(cmds []Cmder) error { diff --git a/universal.go b/universal.go index a6075624..03bfa0fa 100644 --- a/universal.go +++ b/universal.go @@ -155,6 +155,7 @@ type UniversalClient interface { Watch(fn func(*Tx) error, keys ...string) error Process(cmd Cmder) error WrapProcess(fn func(oldProcess func(cmd Cmder) error) func(cmd Cmder) error) + WrapProcessPipeline(fn func(oldProcess func([]Cmder) error) func([]Cmder) error) Subscribe(channels ...string) *PubSub PSubscribe(channels ...string) *PubSub Close() error