NimbusReactiveJsonWebTokenValidator(
            List<GenericJwtClaimsValidator<R>> claimsValidators,
            List<SignatureConfiguration> imperativeSignatureConfigurations,
            List<ReactiveSignatureConfiguration<SignedJWT>> reactiveSignatureConfigurations,
            JsonWebTokenParser<JWT> jsonWebTokenParser,
            ReactiveJsonWebTokenSignatureValidator<SignedJWT> signatureValidator,
            JwtAuthenticationFactory jwtAuthenticationFactory,
            BeanContext beanContext,
            @Value("{" + JwtConfigurationProperties.PREFIX + ".reactive-validator.executor:"
                   + TaskExecutors.BLOCKING + "}") String executor) {
        super(claimsValidators, imperativeSignatureConfigurations, reactiveSignatureConfigurations);
        this.jsonWebTokenParser = jsonWebTokenParser;
        this.signatureValidator = signatureValidator;
        this.jwtAuthenticationFactory = jwtAuthenticationFactory;
        this.scheduler = StringUtils.isEmpty(executor) ? null : getScheduler(beanContext, executor);
    }

    private static Scheduler getScheduler(BeanContext beanContext, String executor) {
        try {
            return Schedulers.fromExecutorService(
                    beanContext.getBean(ExecutorService.class, Qualifiers.byName(executor)));
        } catch (NoSuchBeanException e) {
            throw new ConfigurationException(JwtConfigurationProperties.PREFIX +
                    ".reactive-validator.executor is invalid; no executor configured for name: " +
                    executor, e);
        }
    }

    @Override
    @SingleResult
    public Publisher<Authentication> validateToken(String token, R request) {
        Mono<JWT> publisher = Mono.from(validate(token, request));
        if (scheduler != null) {
            publisher = publisher.subscribeOn(scheduler);
        }
        return publisher
                .map(jwtAuthenticationFactory::createAuthentication)
                .filter(Optional::isPresent)
                .map(Optional::get);
    }