()
| 1514 | } |
| 1515 | |
| 1516 | func (c *Client) Pipeline() Pipeliner { |
| 1517 | pipe := Pipeline{ |
| 1518 | exec: pipelineExecer(c.processPipelineHook), |
| 1519 | } |
| 1520 | pipe.init() |
| 1521 | return &pipe |
| 1522 | } |
| 1523 | |
| 1524 | func (c *Client) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1525 | return c.TxPipeline().Pipelined(ctx, fn) |