updating removeData
parent
95c404dfce
commit
cdf1862c86
|
@ -5,6 +5,7 @@ import earth.krakatao.KraSocketClient;
|
||||||
import java.nio.charset.StandardCharsets;
|
import java.nio.charset.StandardCharsets;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
|
import java.util.Iterator;
|
||||||
import java.util.function.Consumer;
|
import java.util.function.Consumer;
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
|
|
||||||
|
@ -131,7 +132,17 @@ public class KraSocketClientProtocol {
|
||||||
}
|
}
|
||||||
|
|
||||||
public void removeData(int cmdID) {
|
public void removeData(int cmdID) {
|
||||||
this.cmdIDs.remove(cmdID);
|
Iterator<Integer> iterator = this.cmdIDs.iterator();
|
||||||
|
|
||||||
|
KraSocketClient.getLogger().info("before: " + this.cmdIDs);
|
||||||
|
|
||||||
|
while (iterator.hasNext()) {
|
||||||
|
if (iterator.next() == cmdID) {
|
||||||
|
iterator.remove();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
KraSocketClient.getLogger().info("after: " + this.cmdIDs);
|
||||||
|
|
||||||
this.consumerHashMap.remove(cmdID);
|
this.consumerHashMap.remove(cmdID);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue