github.com/go-redis/redis/v8/internal/pool.Conn.WithReader (method)

7 uses

	github.com/go-redis/redis/v8/internal/pool (current package)
		conn.go#L64: func (cn *Conn) WithReader(ctx context.Context, timeout time.Duration, fn func(rd *proto.Reader) error) error {

	github.com/go-redis/redis/v8
		cluster.go#L1184: 			return cn.WithReader(ctx, c.opt.ReadTimeout, func(rd *proto.Reader) error {
		cluster.go#L1342: 			return cn.WithReader(ctx, c.opt.ReadTimeout, func(rd *proto.Reader) error {
		pubsub.go#L378: 	err = cn.WithReader(ctx, timeout, func(rd *proto.Reader) error {
		redis.go#L316: 				err = cn.WithReader(ctx, c.cmdTimeout(cmd), cmd.readReply)
		redis.go#L429: 	err = cn.WithReader(ctx, c.opt.ReadTimeout, func(rd *proto.Reader) error {
		redis.go#L455: 	err = cn.WithReader(ctx, c.opt.ReadTimeout, func(rd *proto.Reader) error {