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