|
|
@ -34,7 +34,7 @@ class OpenGroupV2Poller(private val openGroups: List<OpenGroupV2>, private val e
|
|
|
|
}
|
|
|
|
}
|
|
|
|
val sampleWindow = System.currentTimeMillis() - pollForNewMessagesInterval * 2
|
|
|
|
val sampleWindow = System.currentTimeMillis() - pollForNewMessagesInterval * 2
|
|
|
|
val numberInSample = receivedQueue.toList().filter { it > sampleWindow }.size.coerceAtLeast(1)
|
|
|
|
val numberInSample = receivedQueue.toList().filter { it > sampleWindow }.size.coerceAtLeast(1)
|
|
|
|
return ((2 + (50 / numberInSample / 20)*5) * 1000).toLong()
|
|
|
|
return ((2 + (50 / numberInSample / 20)*10) * 1000).toLong()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// region Settings
|
|
|
|
// region Settings
|
|
|
|