Skip to content

Commit

Permalink
Refactor
Browse files Browse the repository at this point in the history
  • Loading branch information
Mindgamesnl committed Jan 30, 2024
1 parent b789ea8 commit 87df312
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ public void addSubscribe(
lock.unlock();
}

public void flush(ClientConnection toSendTo) {
public void flushDropsAndSubscriptions(ClientConnection toSendTo) {
lock.lock();
if (!dropQueue.isEmpty()) {
String[] streamKeys = dropQueue.toArray(new String[0]);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@ public void run() {

// flush all voicechat updates
for (ClientConnection client : allClients) {
client.getPeerQueue().flush(client);
client.getPeerQueue().flushDropsAndSubscriptions(client);
client.getSession().setResetVc(false);
}

Expand Down

0 comments on commit 87df312

Please sign in to comment.