InsanusMokrassar/tgbotapi
1
0
Fork 0
mirror of https://github.com/InsanusMokrassar/TelegramBotAPI.git synced 2024-06-26 11:38:09 +00:00
Code Releases Activity

fixes

Browse Source
This commit is contained in:
InsanusMokrassar 2023-03-01 12:38:50 +06:00
parent 5a456bcdbf
commit 017d57e5e5
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tgbotapi.utils/src/commonMain/kotlin/dev/inmo/tgbotapi/extensions/utils/updates/retrieving/LongPolling.kt
View File

@ -55,12 +55,17 @@ fun TelegramBot.longPollingFlow(
val updatesHandler: (suspend (List<Update>) -> Unit) = if (mediaGroupsDebounceTimeMillis != null) { val updatesHandler: (suspend (List<Update>) -> Unit) = if (mediaGroupsDebounceTimeMillis != null) {
val scope = CoroutineScope(contextToWork) val scope = CoroutineScope(contextToWork)
val updatesReceiver = scope.updateHandlerWithMediaGroupsAdaptation( val updatesReceiver = scope.updateHandlerWithMediaGroupsAdaptation(
::send, {
withContext(contextToWork) {
send(it)
}
},
mediaGroupsDebounceTimeMillis mediaGroupsDebounceTimeMillis
); );
{ originalUpdates: List<Update> -> { originalUpdates: List<Update> ->
originalUpdates.forEach { originalUpdates.forEach {
updatesReceiver(it) updatesReceiver(it)
lastUpdateIdentifier = maxOf(lastUpdateIdentifier ?: it.updateId, it.updateId)
} }
} }
} else { } else {