refactoring

redisson/src/main/java/org/redisson/command/CommandAsyncService.java

@@ -96,6 +96,12 @@ public class CommandAsyncService implements CommandAsyncExecutor {
         } catch (TimeoutException e) {
             future.completeExceptionally(new RedisTimeoutException("Subscribe timeout: (" + timeout + "ms). Increase 'subscriptionsPerConnection' and/or 'subscriptionConnectionPoolSize' parameters."));
         }
+
+        try {
+            future.join();
+        } catch (CompletionException e) {
+            throw (RuntimeException) e.getCause();
+        }
     }
 
     @Override
@@ -111,6 +117,12 @@ public class CommandAsyncService implements CommandAsyncExecutor {
         } catch (TimeoutException e) {
             future.completeExceptionally(new RedisTimeoutException("Subscribe timeout: (" + timeout + "ms). Increase 'subscriptionsPerConnection' and/or 'subscriptionConnectionPoolSize' parameters."));
         }
+
+        try {
+            future.join();
+        } catch (CompletionException e) {
+            throw (RuntimeException) e.getCause();
+        }
     }
 
     @Override