diff --git a/src/main/kotlin/com/gzzn/omms/msgexchange/ingress/InboxPoller.kt b/src/main/kotlin/com/gzzn/omms/msgexchange/ingress/InboxPoller.kt index d0a5ef4..d9b6e02 100644 --- a/src/main/kotlin/com/gzzn/omms/msgexchange/ingress/InboxPoller.kt +++ b/src/main/kotlin/com/gzzn/omms/msgexchange/ingress/InboxPoller.kt @@ -108,9 +108,9 @@ class InboxPoller( private fun contiguousUpTo(from: Long, rows: List): Long? { var expected = from + 1 var last: Long? = null - for (row in rows) { - if (row.msgId != expected) break - last = row.msgId + for ((msgId, _) in rows) { + if (msgId != expected) break + last = msgId expected++ } return last