diff --git a/SubServers.Bungee/src/net/ME1312/SubServers/Bungee/Network/SubProtocol.java b/SubServers.Bungee/src/net/ME1312/SubServers/Bungee/Network/SubProtocol.java index 979f7d95..4f05cdb3 100644 --- a/SubServers.Bungee/src/net/ME1312/SubServers/Bungee/Network/SubProtocol.java +++ b/SubServers.Bungee/src/net/ME1312/SubServers/Bungee/Network/SubProtocol.java @@ -157,10 +157,7 @@ public class SubProtocol extends SubDataProtocol { subdata.on.closed(server -> plugin.subdata = null); subdata.on.connect(client -> { if (!plugin.getPluginManager().callEvent(new SubNetworkConnectEvent(client.getServer(), client)).isCancelled()) { - client.on.ready(c -> { - ((SubDataClient) c).setBlockSize((int) DataSize.KBB); - plugin.getPluginManager().callEvent(new SubNetworkLoginEvent(c.getServer(), c)); - }); + client.on.ready(c -> plugin.getPluginManager().callEvent(new SubNetworkLoginEvent(c.getServer(), c))); client.on.closed(c -> plugin.getPluginManager().callEvent(new SubNetworkDisconnectEvent(c.value().getServer(), c.value(), c.key()))); return true; } else return false; diff --git a/SubServers.Client/Bukkit/src/net/ME1312/SubServers/Client/Bukkit/Network/SubProtocol.java b/SubServers.Client/Bukkit/src/net/ME1312/SubServers/Client/Bukkit/Network/SubProtocol.java index 0d6689be..f76a5ea6 100644 --- a/SubServers.Client/Bukkit/src/net/ME1312/SubServers/Client/Bukkit/Network/SubProtocol.java +++ b/SubServers.Client/Bukkit/src/net/ME1312/SubServers/Client/Bukkit/Network/SubProtocol.java @@ -166,10 +166,7 @@ public class SubProtocol extends SubDataProtocol { subdata.sendPacket(new PacketLinkServer(plugin, 0)); subdata.sendPacket(new PacketDownloadLang()); - subdata.on.ready(client -> { - ((SubDataClient) client).setBlockSize((int) DataSize.KBB); - Bukkit.getPluginManager().callEvent(new SubNetworkConnectEvent((SubDataClient) client)); - }); + subdata.on.ready(client -> Bukkit.getPluginManager().callEvent(new SubNetworkConnectEvent((SubDataClient) client))); subdata.on.closed(client -> { SubNetworkDisconnectEvent event = new SubNetworkDisconnectEvent(client.value(), client.key()); diff --git a/SubServers.Client/Sponge/src/net/ME1312/SubServers/Client/Sponge/Network/SubProtocol.java b/SubServers.Client/Sponge/src/net/ME1312/SubServers/Client/Sponge/Network/SubProtocol.java index 1431af79..c511e8af 100644 --- a/SubServers.Client/Sponge/src/net/ME1312/SubServers/Client/Sponge/Network/SubProtocol.java +++ b/SubServers.Client/Sponge/src/net/ME1312/SubServers/Client/Sponge/Network/SubProtocol.java @@ -173,10 +173,7 @@ public class SubProtocol extends SubDataProtocol { SubDataClient subdata = super.open(scheduler, logger, address, port); subdata.sendPacket(new PacketLinkServer(plugin, 0)); subdata.sendPacket(new PacketDownloadLang()); - subdata.on.ready(client -> { - ((SubDataClient) client).setBlockSize((int) DataSize.KBB); - Sponge.getEventManager().post(new SubNetworkConnectEvent((SubDataClient) client)); - }); + subdata.on.ready(client -> Sponge.getEventManager().post(new SubNetworkConnectEvent((SubDataClient) client))); subdata.on.closed(client -> { SubNetworkDisconnectEvent event = new SubNetworkDisconnectEvent(client.value(), client.key()); Sponge.getEventManager().post(event); diff --git a/SubServers.Host/src/net/ME1312/SubServers/Host/Network/SubProtocol.java b/SubServers.Host/src/net/ME1312/SubServers/Host/Network/SubProtocol.java index 3f15c0f1..87eab820 100644 --- a/SubServers.Host/src/net/ME1312/SubServers/Host/Network/SubProtocol.java +++ b/SubServers.Host/src/net/ME1312/SubServers/Host/Network/SubProtocol.java @@ -164,10 +164,7 @@ public class SubProtocol extends SubDataProtocol { subdata.sendPacket(new PacketExDownloadTemplates(host)); subdata.sendPacket(new PacketDownloadLang()); subdata.sendPacket(new PacketOutExRequestQueue()); - subdata.on.ready(client -> { - ((SubDataClient) client).setBlockSize((int) DataSize.KBB); - host.engine.getPluginManager().executeEvent(new SubNetworkConnectEvent((SubDataClient) client)); - }); + subdata.on.ready(client -> host.engine.getPluginManager().executeEvent(new SubNetworkConnectEvent((SubDataClient) client))); subdata.on.closed(client -> { SubNetworkDisconnectEvent event = new SubNetworkDisconnectEvent(client.value(), client.key()); host.engine.getPluginManager().executeEvent(event); diff --git a/SubServers.Sync/src/net/ME1312/SubServers/Sync/Network/SubProtocol.java b/SubServers.Sync/src/net/ME1312/SubServers/Sync/Network/SubProtocol.java index 9e5c809c..984d16eb 100644 --- a/SubServers.Sync/src/net/ME1312/SubServers/Sync/Network/SubProtocol.java +++ b/SubServers.Sync/src/net/ME1312/SubServers/Sync/Network/SubProtocol.java @@ -200,10 +200,7 @@ public class SubProtocol extends SubDataProtocol { }); })); - subdata.on.ready(client -> { - ((SubDataClient) client).setBlockSize((int) DataSize.KBB); - plugin.getPluginManager().callEvent(new SubNetworkConnectEvent((SubDataClient) client)); - }); + subdata.on.ready(client -> plugin.getPluginManager().callEvent(new SubNetworkConnectEvent((SubDataClient) client))); subdata.on.closed(client -> { SubNetworkDisconnectEvent event = new SubNetworkDisconnectEvent(client.value(), client.key()); plugin.getPluginManager().callEvent(event);