andreacavalli/tdlib-session-container
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Add utility method

Browse Source
This commit is contained in:
Andrea Cavalli 2021-08-05 21:28:57 +02:00
parent 0b317cc545
commit 45af656d90
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/it/tdlight/utils/MonoUtils.java
View File

@ -33,6 +33,7 @@ import org.jetbrains.annotations.Nullable;
import org.reactivestreams.Publisher; import org.reactivestreams.Publisher;
import org.reactivestreams.Subscription; import org.reactivestreams.Subscription;
import org.warp.commonutils.concurrency.future.CompletableFutureUtils; import org.warp.commonutils.concurrency.future.CompletableFutureUtils;
import org.warp.commonutils.functional.IOConsumer;
import org.warp.commonutils.log.Logger; import org.warp.commonutils.log.Logger;
import org.warp.commonutils.log.LoggerFactory; import org.warp.commonutils.log.LoggerFactory;
import reactor.core.CoreSubscriber; import reactor.core.CoreSubscriber;
@ -287,4 +288,15 @@ public class MonoUtils {
.defaultIfEmpty(false); .defaultIfEmpty(false);
} }
@FunctionalInterface
public interface VoidCallable {
void call() throws Exception;
}
public static Mono<?> fromVoidCallable(VoidCallable callable) {
return Mono.fromCallable(() -> {
callable.call();
return null;
});
}
} }