mirror of
https://gitlab.futo.org/videostreaming/grayjay.git
synced 2025-08-02 22:30:40 +00:00
Cleanup.
This commit is contained in:
parent
8b20b4909f
commit
265ff7b105
1 changed files with 2 additions and 1 deletions
|
@ -259,10 +259,11 @@ class StateSubscriptions {
|
||||||
val subUrls = getSubscriptions().parallelStream().map {
|
val subUrls = getSubscriptions().parallelStream().map {
|
||||||
if(usePolycentric) {
|
if(usePolycentric) {
|
||||||
val result = StatePolycentric.instance.getChannelUrlsWithUpdateResult(it.channel.url, it.channel.id, polycentricBudget <= 0);
|
val result = StatePolycentric.instance.getChannelUrlsWithUpdateResult(it.channel.url, it.channel.id, polycentricBudget <= 0);
|
||||||
if(result.first)
|
if(result.first) {
|
||||||
synchronized(lock) {
|
synchronized(lock) {
|
||||||
polycentricBudget--;
|
polycentricBudget--;
|
||||||
}
|
}
|
||||||
|
}
|
||||||
Pair(it, result.second);
|
Pair(it, result.second);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue