Spring/spring-graphql
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Polishing

Browse Source
This commit is contained in:
rstoyanchev
2023-03-03 12:09:25 +00:00
parent d292ffdc7f
commit 610a658f49
1 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
spring-graphql/src/main/java/org/springframework/graphql/data/method/InvocableHandlerMethodSupport.java
View File

@@ -17,13 +17,12 @@ package org.springframework.graphql.data.method;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import graphql.GraphQLContext;
import io.micrometer.context.ContextSnapshot;
@@ -132,16 +131,19 @@ public abstract class InvocableHandlerMethodSupport extends HandlerMethod {
*/
@SuppressWarnings("unchecked")
protected Mono<Object[]> toArgsMono(Object[] args) {
List<Mono<Object>> monoList = Arrays.stream(args)
.map(arg -> {
Mono<Object> argMono = (arg instanceof Mono ? (Mono<Object>) arg : Mono.justOrEmpty(arg));
return argMono.defaultIfEmpty(NO_VALUE);
})
.collect(Collectors.toList());
return Mono.zip(monoList,
values -> Stream.of(values).map(value -> value != NO_VALUE ? value : null).toArray());
List<Mono<Object>> monoList = new ArrayList<>();
for (Object arg : args) {
Mono<Object> argMono = (arg instanceof Mono ? (Mono<Object>) arg : Mono.justOrEmpty(arg));
monoList.add(argMono.defaultIfEmpty(NO_VALUE));
}
return Mono.zip(monoList, values -> {
for (int i = 0; i < values.length; i++) {
if (values[i] == NO_VALUE) {
values[i] = null;
}
}
return values;
});
}
}