This commit is contained in:
Koen 2023-12-08 14:53:57 +01:00
parent 8b20b4909f
commit 33780f1046

View file

@ -259,10 +259,11 @@ class StateSubscriptions {
val subUrls = getSubscriptions().parallelStream().map {
if(usePolycentric) {
val result = StatePolycentric.instance.getChannelUrlsWithUpdateResult(it.channel.url, it.channel.id, polycentricBudget <= 0);
if(result.first)
if(result.first) {
synchronized(lock) {
polycentricBudget--;
}
}
Pair(it, result.second);
}
else