Skip to content

Commit 23d1b0e

Browse files
committed
Polishing
1 parent da0a36b commit 23d1b0e

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

spring-webflux/src/main/java/org/springframework/web/reactive/result/method/InvocableHandlerMethod.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
import kotlin.reflect.jvm.KCallablesJvm;
3838
import kotlin.reflect.jvm.ReflectJvmMapping;
3939
import org.jspecify.annotations.Nullable;
40+
import org.reactivestreams.Publisher;
4041
import reactor.core.publisher.Mono;
4142
import reactor.core.publisher.SynchronousSink;
4243
import reactor.core.scheduler.Scheduler;
@@ -332,7 +333,7 @@ private static class KotlinDelegate {
332333

333334
if (isSuspendingFunction) {
334335
Object coroutineContext = exchange.getAttribute(COROUTINE_CONTEXT_ATTRIBUTE);
335-
Object result = (coroutineContext == null ? CoroutinesUtils.invokeSuspendingFunction(method, target, args) :
336+
Publisher<?> result = (coroutineContext == null ? CoroutinesUtils.invokeSuspendingFunction(method, target, args) :
336337
CoroutinesUtils.invokeSuspendingFunction((CoroutineContext) coroutineContext, method, target, args));
337338
return (result instanceof Mono<?> mono ? mono.handle(KotlinDelegate::handleResult) : result);
338339
}

0 commit comments

Comments
 (0)