diff --git a/G-Earth/src/main/java/gearth/protocol/packethandler/IncomingPacketHandler.java b/G-Earth/src/main/java/gearth/protocol/packethandler/IncomingPacketHandler.java index 6e7ee56..2d46203 100644 --- a/G-Earth/src/main/java/gearth/protocol/packethandler/IncomingPacketHandler.java +++ b/G-Earth/src/main/java/gearth/protocol/packethandler/IncomingPacketHandler.java @@ -24,7 +24,11 @@ public class IncomingPacketHandler extends PacketHandler { isEncryptedStream = packet.readBoolean(); outgoingHandler.isEncryptedStream = true; } - else if (message.getIndex() > 3) { + else if (isDataStream && message.getPacket().structureEquals("s") && message.getPacket().length() > 200) { + ((Observable)trafficObservables[0]).removeListener(this); + outgoingHandler.isEncryptedStream = true; + } + else if (message.getIndex() > 1) { ((Observable)trafficObservables[0]).removeListener(this); } }