diff --git a/tgbotapi.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/updates/retrieving/LongPolling.kt b/tgbotapi.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/updates/retrieving/LongPolling.kt index 5849c705df..9c5fec7946 100644 --- a/tgbotapi.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/updates/retrieving/LongPolling.kt +++ b/tgbotapi.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/updates/retrieving/LongPolling.kt @@ -55,12 +55,17 @@ fun TelegramBot.longPollingFlow( val updatesHandler: (suspend (List) -> Unit) = if (mediaGroupsDebounceTimeMillis != null) { val scope = CoroutineScope(contextToWork) val updatesReceiver = scope.updateHandlerWithMediaGroupsAdaptation( - ::send, + { + withContext(contextToWork) { + send(it) + } + }, mediaGroupsDebounceTimeMillis ); { originalUpdates: List -> originalUpdates.forEach { updatesReceiver(it) + lastUpdateIdentifier = maxOf(lastUpdateIdentifier ?: it.updateId, it.updateId) } } } else {