docs: protected <K, V> StatefulRedisPubSubConnectionImpl<K, V> newStatefulRedisPubSubConnection(PubSubEndpoint<K, V> endpoint,
              RedisChannelWriter channelWriter, RedisCodec<K, V> codec, Duration timeout) {
          return new StatefulRedisPubSubConnectionImpl<>(endpoint, channelWriter, codec, timeout);
      }