|
|
|
|
@ -372,6 +372,7 @@ public abstract class AopUtils {
@@ -372,6 +372,7 @@ public abstract class AopUtils {
|
|
|
|
|
|
|
|
|
|
public static Publisher<?> invokeSuspendingFunction(Method method, Object target, Object... args) { |
|
|
|
|
Continuation<?> continuation = (Continuation<?>) args[args.length -1]; |
|
|
|
|
Assert.state(continuation != null, "No Continuation available"); |
|
|
|
|
CoroutineContext context = continuation.getContext().minusKey(Job.Key); |
|
|
|
|
return CoroutinesUtils.invokeSuspendingFunction(context, method, target, args); |
|
|
|
|
} |
|
|
|
|
|