diff --git a/src/main/java/com/github/manevolent/ts3j/protocol/packet/fragment/PacketReassembly.java b/src/main/java/com/github/manevolent/ts3j/protocol/packet/fragment/PacketReassembly.java index 5214b74..39089eb 100644 --- a/src/main/java/com/github/manevolent/ts3j/protocol/packet/fragment/PacketReassembly.java +++ b/src/main/java/com/github/manevolent/ts3j/protocol/packet/fragment/PacketReassembly.java @@ -68,7 +68,7 @@ public class PacketReassembly { reassembledPacket.readBody(reassemblyBuffer); // Remove read packets - for (Integer packetId : packetIds) queue.remove(packetId); + packetIds.forEach(queue::remove); return reassembledPacket; } catch (Exception ex) { diff --git a/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java b/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java index 14f2dec..73ab324 100644 --- a/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java +++ b/src/main/java/com/github/manevolent/ts3j/protocol/socket/client/LocalTeamspeakClientSocket.java @@ -267,7 +267,7 @@ public class LocalTeamspeakClientSocket microphoneThread = new HighPrecisionRecurrentTask( 20, - 0.020F, + 0.01F, new MicrophoneTask() ); microphoneThread.setDaemon(true);