(ctx context.Context, fn func(Pipeliner) error)
| 1679 | } |
| 1680 | |
| 1681 | func (c *Conn) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1682 | return c.Pipeline().Pipelined(ctx, fn) |
| 1683 | } |
| 1684 | |
| 1685 | func (c *Conn) Pipeline() Pipeliner { |
| 1686 | pipe := Pipeline{ |