Update ResponseReceiver.java

This commit is contained in:
Andrea Cavalli 2020-10-13 03:00:17 +02:00
parent f38fe387a6
commit ce68fb92f8

View File

@ -70,13 +70,17 @@ public class ResponseReceiver extends Thread implements AutoCloseable {
eventsHandler.handleClientEvents(clientId, lastClientClosed, clientEventIds, clientEvents); eventsHandler.handleClientEvents(clientId, lastClientClosed, clientEventIds, clientEvents);
} }
if (i < resultsCount) {
lastClientId = clientIds[sortIndex[i]]; lastClientId = clientIds[sortIndex[i]];
lastClientIdEventsCount = 0; lastClientIdEventsCount = 0;
lastClientClosed = false; lastClientClosed = false;
} }
}
if (i < resultsCount) {
lastClientIdEventsCount++; lastClientIdEventsCount++;
} }
}
Arrays.fill(events, null); Arrays.fill(events, null);
} }
} finally { } finally {