docs: public StatefulRedisPubSubConnection<String, String> connectPubSub(RedisURI redisURI) {
  
          assertNotNull(redisURI);
          return getConnection(connectPubSubAsync(newStringStringCodec(), redisURI, redisURI.getTimeout()));
      }