iktdev/eventi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 40 Wiki Activity

Removed nanosec

Browse Source
This commit is contained in:
Brage Skjønborg 2026-01-22 03:01:12 +01:00
parent 4d213a2b23
commit 674a536818
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/kotlin/no/iktdev/eventi/events/EventPollerImplementation.kt
View File

@ -60,8 +60,9 @@ abstract class EventPollerImplementation(
dispatchQueue.dispatch(referenceId, events, dispatcher)
}
val maxPersistedAt = newPersisted.maxOf { it.persistedAt }
log.debug { "Updating lastSeenTime from $lastSeenTime to ${minOf(pollStartedAt, maxPersistedAt).plusNanos(1)}" }
lastSeenTime = minOf(pollStartedAt, maxPersistedAt).plusNanos(1)
val newCheckpointTime = minOf(pollStartedAt, maxPersistedAt)
log.debug { "Updating lastSeenTime from $lastSeenTime to $newCheckpointTime" }
lastSeenTime = newCheckpointTime
}
}