docs: public <K, V> ConnectionFuture<StatefulRedisPubSubConnection<K, V>> connectPubSubAsync(RedisCodec<K, V> codec,
              RedisURI redisURI) {
  
          assertNotNull(redisURI);
          return transformAsyncConnectionException(connectPubSubAsync(codec, redisURI, redisURI.getTimeout()));
      }