Исправление handleUpdate
This commit is contained in:
parent
f5368aecaf
commit
57063b30ee
@ -57,7 +57,7 @@ public class TelegramPollingBot extends TelegramLongPollingBot implements Telegr
|
|||||||
if (update != null && eventDistributor != null) {
|
if (update != null && eventDistributor != null) {
|
||||||
Uni.createFrom().voidItem()
|
Uni.createFrom().voidItem()
|
||||||
.emitOn(command -> Context.newInstance(getOrCreateDuplicatedContext(vertx)).runOnContext(command))
|
.emitOn(command -> Context.newInstance(getOrCreateDuplicatedContext(vertx)).runOnContext(command))
|
||||||
.replaceWith(() -> eventDistributor.processing(update))
|
.replaceWith(eventDistributor.processing(update))
|
||||||
.subscribe().asCompletionStage();
|
.subscribe().asCompletionStage();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user