()
| 1683 | } |
| 1684 | |
| 1685 | func (c *Conn) Pipeline() Pipeliner { |
| 1686 | pipe := Pipeline{ |
| 1687 | exec: c.processPipelineHook, |
| 1688 | } |
| 1689 | pipe.init() |
| 1690 | return &pipe |
| 1691 | } |
| 1692 | |
| 1693 | func (c *Conn) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1694 | return c.TxPipeline().Pipelined(ctx, fn) |