Mono.currentContext()->subscriberContext()
Fixing refactoring by Reactor
This commit is contained in:
parent
b3ad174ee2
commit
72f139a824
|
|
@ -86,7 +86,7 @@ public class PrePostAdviceMethodInterceptor implements MethodInterceptor {
|
||||||
.getAttributes(method, targetClass);
|
.getAttributes(method, targetClass);
|
||||||
|
|
||||||
PreInvocationAttribute preAttr = findPreInvocationAttribute(attributes);
|
PreInvocationAttribute preAttr = findPreInvocationAttribute(attributes);
|
||||||
Mono<Authentication> toInvoke = Mono.currentContext()
|
Mono<Authentication> toInvoke = Mono.subscriberContext()
|
||||||
.defaultIfEmpty(Context.empty())
|
.defaultIfEmpty(Context.empty())
|
||||||
.flatMap( cxt -> cxt.getOrDefault(Authentication.class, Mono.just(anonymous)))
|
.flatMap( cxt -> cxt.getOrDefault(Authentication.class, Mono.just(anonymous)))
|
||||||
.filter( auth -> this.preAdvice.before(auth, invocation, preAttr))
|
.filter( auth -> this.preAdvice.before(auth, invocation, preAttr))
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue