|
@@ -20,8 +20,8 @@ import java.lang.reflect.Method;
|
|
|
import java.util.Collection;
|
|
|
|
|
|
import kotlin.coroutines.Continuation;
|
|
|
-import kotlinx.coroutines.reactive.AwaitKt;
|
|
|
import kotlinx.coroutines.reactive.ReactiveFlowKt;
|
|
|
+import kotlinx.coroutines.reactor.MonoKt;
|
|
|
import org.aopalliance.intercept.MethodInterceptor;
|
|
|
import org.aopalliance.intercept.MethodInvocation;
|
|
|
import org.reactivestreams.Publisher;
|
|
@@ -202,7 +202,7 @@ public class PrePostAdviceReactiveMethodInterceptor implements MethodInterceptor
|
|
|
}
|
|
|
|
|
|
private static Object awaitSingleOrNull(Publisher<?> publisher, Object continuation) {
|
|
|
- return AwaitKt.awaitSingleOrNull(publisher, (Continuation<Object>) continuation);
|
|
|
+ return MonoKt.awaitSingleOrNull(publisher, (Continuation<?>) continuation);
|
|
|
}
|
|
|
|
|
|
}
|