()
| 298 | } |
| 299 | |
| 300 | func (c *Client) subscriptionClient() (*redis.Client, error) { |
| 301 | if errEnsure := c.ensureClients(); errEnsure != nil { |
| 302 | return nil, errEnsure |
| 303 | } |
| 304 | c.mu.Lock() |
| 305 | sub := c.sub |
| 306 | c.mu.Unlock() |
| 307 | if sub == nil { |
| 308 | return nil, ErrNotConnected |
| 309 | } |
| 310 | return sub, nil |
| 311 | } |
| 312 | |
| 313 | func (c *Client) Ping(ctx context.Context) error { |
| 314 | cmd, errClient := c.commandClient() |
no test coverage detected