diff --git a/src/main/java/it/tdlight/utils/MonoUtils.java b/src/main/java/it/tdlight/utils/MonoUtils.java index f09f637..9648479 100644 --- a/src/main/java/it/tdlight/utils/MonoUtils.java +++ b/src/main/java/it/tdlight/utils/MonoUtils.java @@ -151,6 +151,14 @@ public class MonoUtils { }); } + public static Mono orElseLogSkipError(TdResult optional) { + if (optional.failed()) { + logger.error("Received TDLib error: {}", optional.cause()); + return Mono.empty(); + } + return Mono.just(optional.result()); + } + public static Mono thenOrLogRepeatError(Supplier>> optionalMono) { return Mono.defer(() -> optionalMono.get().handle((TdResult optional, SynchronousSink sink) -> { if (optional.succeeded()) {