(ctx context.Context, fn func(Pipeliner) error)
| 1522 | } |
| 1523 | |
| 1524 | func (c *Client) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1525 | return c.TxPipeline().Pipelined(ctx, fn) |
| 1526 | } |
| 1527 | |
| 1528 | // TxPipeline acts like Pipeline, but wraps queued commands with MULTI/EXEC. |
| 1529 | func (c *Client) TxPipeline() Pipeliner { |