(ctx context.Context, fn func(Pipeliner) error)
| 1510 | } |
| 1511 | |
| 1512 | func (c *Client) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1513 | return c.Pipeline().Pipelined(ctx, fn) |
| 1514 | } |
| 1515 | |
| 1516 | func (c *Client) Pipeline() Pipeliner { |
| 1517 | pipe := Pipeline{ |