From 641a57ec9302ef694c39b52c8dd5cced509d237c Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Wed, 27 Jan 2016 14:59:19 +0000 Subject: [PATCH] no need to convert to array list with last zip signature --- .../web/reactive/method/InvocableHandlerMethod.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/spring-web-reactive/src/main/java/org/springframework/web/reactive/method/InvocableHandlerMethod.java b/spring-web-reactive/src/main/java/org/springframework/web/reactive/method/InvocableHandlerMethod.java index 3508c1565ca..855d6dc5caa 100644 --- a/spring-web-reactive/src/main/java/org/springframework/web/reactive/method/InvocableHandlerMethod.java +++ b/spring-web-reactive/src/main/java/org/springframework/web/reactive/method/InvocableHandlerMethod.java @@ -112,7 +112,7 @@ public class InvocableHandlerMethod extends HandlerMethod { if (!ObjectUtils.isEmpty(providedArgs)) { for (Object providedArg : providedArgs) { if (param.getParameterType().isInstance(providedArg)) { - return Mono.just(providedArg); + return Mono.just(providedArg).log("reactor.resolved"); } } } @@ -123,7 +123,8 @@ public class InvocableHandlerMethod extends HandlerMethod { try { return resolver.resolveArgument(param, exchange) .defaultIfEmpty(NO_VALUE) - .otherwise(ex -> Mono.error(getArgError("Error resolving ", param, ex))); + .otherwise(ex -> Mono.error(getArgError("Error resolving ", param, ex))) + .log("reactor.unresolved"); } catch (Exception ex) { throw getArgError("Error resolving ", param, ex); @@ -131,8 +132,8 @@ public class InvocableHandlerMethod extends HandlerMethod { }) .collect(Collectors.toList()); - return Mono.when(monos).map(args -> - Stream.of(args.toArray()).map(o -> o != NO_VALUE ? o : null).toArray()); + return Mono.when(monos).log("reactor.unresolved").map(args -> + Stream.of(args).map(o -> o != NO_VALUE ? o : null).toArray()); } catch (Throwable ex) { return Mono.error(ex);