|
|
|
@ -75,7 +75,7 @@ public class InvocableHandlerMethodTests { |
|
|
|
InvocableHandlerMethod hm = createHandlerMethod("noArgs"); |
|
|
|
InvocableHandlerMethod hm = createHandlerMethod("noArgs"); |
|
|
|
|
|
|
|
|
|
|
|
Mono<HandlerResult> mono = hm.invokeForRequest(this.exchange, this.model); |
|
|
|
Mono<HandlerResult> mono = hm.invokeForRequest(this.exchange, this.model); |
|
|
|
HandlerResult value = mono.get(); |
|
|
|
HandlerResult value = mono.block(); |
|
|
|
|
|
|
|
|
|
|
|
assertNotNull(value); |
|
|
|
assertNotNull(value); |
|
|
|
assertEquals("success", value.getReturnValue().get()); |
|
|
|
assertEquals("success", value.getReturnValue().get()); |
|
|
|
@ -204,7 +204,7 @@ public class InvocableHandlerMethodTests { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private Throwable awaitErrorSignal(Publisher<?> publisher) throws Exception { |
|
|
|
private Throwable awaitErrorSignal(Publisher<?> publisher) throws Exception { |
|
|
|
Signal<?> signal = Flux.from(publisher).materialize().toList().get().get(0); |
|
|
|
Signal<?> signal = Flux.from(publisher).materialize().collectList().block().get(0); |
|
|
|
assertEquals("Unexpected signal: " + signal, SignalKind.onError, signal.getType()); |
|
|
|
assertEquals("Unexpected signal: " + signal, SignalKind.onError, signal.getType()); |
|
|
|
return signal.getThrowable(); |
|
|
|
return signal.getThrowable(); |
|
|
|
} |
|
|
|
} |
|
|
|
|