From cb1d0dfe3ab6c7c821497eeea8a966debc6379e8 Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Tue, 20 Oct 2020 02:13:58 +0200 Subject: [PATCH] Update MonoUtils.java --- src/main/java/it/tdlight/utils/MonoUtils.java | 8 ++++++++ 1 file changed, 8 insertions(+) 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()) {