diff --git a/telegram-core/telegram-core-quarkus/src/main/java/dev/struchkov/godfather/telegram/quarkus/core/TelegramPollingBot.java b/telegram-core/telegram-core-quarkus/src/main/java/dev/struchkov/godfather/telegram/quarkus/core/TelegramPollingBot.java index 77a800d..389a442 100644 --- a/telegram-core/telegram-core-quarkus/src/main/java/dev/struchkov/godfather/telegram/quarkus/core/TelegramPollingBot.java +++ b/telegram-core/telegram-core-quarkus/src/main/java/dev/struchkov/godfather/telegram/quarkus/core/TelegramPollingBot.java @@ -57,7 +57,7 @@ public class TelegramPollingBot extends TelegramLongPollingBot implements Telegr if (update != null && eventDistributor != null) { Uni.createFrom().voidItem() .emitOn(command -> Context.newInstance(getOrCreateDuplicatedContext(vertx)).runOnContext(command)) - .replaceWith(() -> eventDistributor.processing(update)) + .replaceWith(eventDistributor.processing(update)) .subscribe().asCompletionStage(); } }