minor coding style fix

src/sw/redis++/async_connection_pool.h

@@ -163,6 +163,8 @@ class SafeAsyncConnection {
     }
 
     AsyncConnection& connection() {
+        assert(_connection);
+
         return *_connection;
     }
 
@@ -193,17 +195,17 @@ class GuardedAsyncConnection {
         }
     }
 
-    AsyncConnectionSPtr& connection() {
-        return _connection;
+    AsyncConnection& connection() {
+        assert(_connection);
+
+        return *_connection;
     }
 
 private:
     AsyncConnectionPoolSPtr _pool;
     AsyncConnectionSPtr _connection;
 };
 
-using GuardedAsyncConnectionSPtr = std::shared_ptr<GuardedAsyncConnection>;
-
 }
 
 }

src/sw/redis++/async_redis_cluster.h

@@ -750,7 +750,7 @@ class AsyncRedisCluster {
 
         GuardedAsyncConnection connection(pool);
 
-        return connection.connection()->send<Result>(_pool, key, std::forward<Args>(args)...);
+        return connection.connection().send<Result>(_pool, key, std::forward<Args>(args)...);
     }
 
     template <typename Result, typename ResultParser, typename ...Args>
@@ -762,7 +762,7 @@ class AsyncRedisCluster {
 
         GuardedAsyncConnection connection(pool);
 
-        return connection.connection()->
+        return connection.connection().
             send<Result, ResultParser>(_pool, key, std::forward<Args>(args)...);
     }
 

src/sw/redis++/async_shards_pool.cpp

@@ -342,7 +342,7 @@ bool AsyncShardsPool::_redeliver_events(std::queue<RedeliverEvent> &events) {
 
             GuardedAsyncConnection connection(pool);
 
-            connection.connection()->send(std::move(async_event));
+            connection.connection().send(std::move(async_event));
         } catch (...) {
             event.event->set_exception(std::current_exception());
         }