Skip to content

Commit 613b16c

Browse files
Park9eonjzheaux
authored andcommitted
NimbusReactiveJwtDecoder support mono chain
Supports reactive exception handling when using PublicKeyReactiveJwtDecoderBuilder and SecretKeyReactiveJwtDecoderBuilder
1 parent 53a273e commit 613b16c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

oauth2/oauth2-jose/src/main/java/org/springframework/security/oauth2/jwt/NimbusReactiveJwtDecoder.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2002-2021 the original author or authors.
2+
* Copyright 2002-2023 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -488,7 +488,7 @@ Converter<JWT, Mono<JWTClaimsSet>> processor() {
488488
jwtProcessor.setJWTClaimsSetVerifier((claims, context) -> {
489489
});
490490
this.jwtProcessorCustomizer.accept(jwtProcessor);
491-
return (jwt) -> Mono.just(createClaimsSet(jwtProcessor, jwt, null));
491+
return (jwt) -> Mono.fromCallable(() -> createClaimsSet(jwtProcessor, jwt, null));
492492
}
493493

494494
}
@@ -563,7 +563,7 @@ Converter<JWT, Mono<JWTClaimsSet>> processor() {
563563
jwtProcessor.setJWTClaimsSetVerifier((claims, context) -> {
564564
});
565565
this.jwtProcessorCustomizer.accept(jwtProcessor);
566-
return (jwt) -> Mono.just(createClaimsSet(jwtProcessor, jwt, null));
566+
return (jwt) -> Mono.fromCallable(() -> createClaimsSet(jwtProcessor, jwt, null));
567567
}
568568

569569
}

0 commit comments

Comments
 (0)