(ctx context.Context, fn func(Pipeliner) error)
| 1691 | } |
| 1692 | |
| 1693 | func (c *Conn) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { |
| 1694 | return c.TxPipeline().Pipelined(ctx, fn) |
| 1695 | } |
| 1696 | |
| 1697 | // TxPipeline acts like Pipeline, but wraps queued commands with MULTI/EXEC. |
| 1698 | func (c *Conn) TxPipeline() Pipeliner { |
nothing calls this directly
no test coverage detected