Skip to content

Commit

Permalink
Polishing
Browse files Browse the repository at this point in the history
Closes gh-31846
  • Loading branch information
sdeleuze committed Dec 15, 2023
1 parent bf08193 commit d2aa6a9
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -41,12 +41,12 @@
import kotlinx.coroutines.reactor.MonoKt;
import kotlinx.coroutines.reactor.ReactorFlowKt;
import org.reactivestreams.Publisher;
import org.springframework.util.ReflectionUtils;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import org.springframework.util.Assert;
import org.springframework.util.CollectionUtils;
import org.springframework.util.ReflectionUtils;

/**
* Utilities for working with Kotlin Coroutines.
Expand Down Expand Up @@ -125,7 +125,8 @@ public static Publisher<?> invokeSuspendingFunction(CoroutineContext context, Me
Method[] methods = ReflectionUtils.getUniqueDeclaredMethods(javaClass, boxImplFilter);
Assert.state(methods.length == 1, "Unable to find a single box-impl synthetic static method in " + javaClass.getName());
argMap.put(parameter, ReflectionUtils.invokeMethod(methods[0], null, args[index]));
} else {
}
else {
argMap.put(parameter, args[index]);
}
}
Expand Down

0 comments on commit d2aa6a9

Please sign in to comment.