Forgot to add this - part of previous commit

This commit is contained in:
Waverunner
2014-08-16 23:15:07 -04:00
parent 40ea74e03d
commit 810a80cc24
+2 -2
View File
@@ -344,9 +344,9 @@ public class ConnectionService implements INetworkDispatch {
object.setAttachment("disconnectTask", null);
try {
List<ScheduledFuture<?>> schedulers = core.playerService.getSchedulers().get(object.getObjectID());
Map<String, ScheduledFuture<?>> schedulers = core.playerService.getSchedulers().get(object.getObjectID());
if(schedulers != null) {
schedulers.forEach(s -> s.cancel(true));
schedulers.forEach((s, thread) -> thread.cancel(true));
schedulers.clear();
}
core.playerService.getSchedulers().remove(object.getObjectID());