(&self)
| 88 | |
| 89 | impl RedisClient { |
| 90 | async fn get_async_connection(&self) -> Result<RedisConnection> { |
| 91 | match self { |
| 92 | RedisClient::Client(c) => Ok(RedisConnection::Client( |
| 93 | c.get_multiplexed_async_connection().await?, |
| 94 | )), |
| 95 | RedisClient::ClusterClient(c) => Ok(RedisConnection::ClusterClient( |
| 96 | c.get_async_connection().await?, |
| 97 | )), |
| 98 | } |
| 99 | } |
| 100 | } |
| 101 | |
| 102 | enum RedisConnection { |