Update MonoUtils.java

This commit is contained in:
Andrea Cavalli 2021-02-10 18:16:15 +01:00
parent f15303cb85
commit 39516047f7

View File

@ -54,6 +54,12 @@ public class MonoUtils {
private static final Logger logger = LoggerFactory.getLogger(MonoUtils.class);
public static <T> Mono<T> notImplemented() {
return Mono.fromCallable(() -> {
throw new UnsupportedOperationException("Method not implemented");
});
}
public static <T> Handler<AsyncResult<T>> toHandler(SynchronousSink<T> sink) {
return event -> {
if (event.succeeded()) {