docs: @SuppressWarnings("unchecked")
      public <K, V> CompletableFuture<StatefulRedisClusterPubSubConnection<K, V>> connectPubSubAsync(RedisCodec<K, V> codec) {
          return transformAsyncConnectionException(connectClusterPubSubAsync(codec), getInitialUris());
      }