continue experiments with generics in network

Author: JavaSaBr

rlib-network/src/loadTest/java/javasabr/rlib/network/StringNetworkLoadTest.java

@@ -19,6 +19,8 @@
 import javasabr.rlib.network.client.ClientNetwork;
 import javasabr.rlib.network.impl.DefaultBufferAllocator;
 import javasabr.rlib.network.impl.StringDataConnection;
+import javasabr.rlib.network.impl.StringDataSslConnection;
+import javasabr.rlib.network.packet.impl.StringReadableNetworkPacket;
 import javasabr.rlib.network.packet.impl.StringWritableNetworkPacket;
 import javasabr.rlib.network.server.ServerNetwork;
 import lombok.CustomLog;
@@ -141,10 +143,11 @@ void testServerWithMultiplyClients() {
 
  serverNetwork.onAccept(accepted -> accepted
  .onReceive((connection, packet) -> {
+ StringReadableNetworkPacket<StringDataConnection> receivedPacket = (StringReadableNetworkPacket<StringDataConnection>) packet;
  statistics
  .receivedClientPackersPerSecond()
  .accumulate(1);
- connection.send(new StringWritableNetworkPacket<>("Echo: " + packet.data()));
+ connection.send(new StringWritableNetworkPacket<>("Echo: " + receivedPacket.data()));
  statistics
  .sentEchoPackersPerSecond()
  .accumulate(1);

rlib-network/src/loadTest/java/javasabr/rlib/network/StringSslNetworkLoadTest.java

@@ -23,6 +23,7 @@
 import javasabr.rlib.network.impl.StringDataSslConnection;
 import javasabr.rlib.network.packet.impl.AbstractSslNetworkPacketReader;
 import javasabr.rlib.network.packet.impl.AbstractSslNetworkPacketWriter;
+import javasabr.rlib.network.packet.impl.StringReadableNetworkPacket;
 import javasabr.rlib.network.packet.impl.StringWritableNetworkPacket;
 import javasabr.rlib.network.server.ServerNetwork;
 import javasabr.rlib.network.util.NetworkUtils;
@@ -153,10 +154,11 @@ void testServerWithMultiplyClients() {
 
  serverNetwork.onAccept(accepted -> accepted
  .onReceive((connection, packet) -> {
+ StringReadableNetworkPacket<StringDataSslConnection> receivedPacket = (StringReadableNetworkPacket<StringDataSslConnection>) packet;
  statistics
  .receivedClientPackersPerSecond()
  .accumulate(1);
- connection.send(new StringWritableNetworkPacket<>("Echo: " + packet.data()));
+ connection.send(new StringWritableNetworkPacket<>("Echo: " + receivedPacket.data()));
  statistics
  .sentEchoPackersPerSecond()
  .accumulate(1);

rlib-network/src/test/java/javasabr/rlib/network/StringNetworkTest.java

@@ -38,7 +38,6 @@
 @CustomLog
 public class StringNetworkTest extends BaseNetworkTest {
 
-
  @Test
  @SneakyThrows
  void echoNetworkTest() {

rlib-network/src/test/java/javasabr/rlib/network/StringSslNetworkTest.java

@@ -123,7 +123,7 @@ void serverSslNetworkTest() {
  .flip();
  short packetLength = buffer.getShort();
 
- StringReadableNetworkPacket<StringDataSslConnection> response = new StringReadableNetworkPacket<>();
+ var response = new StringReadableNetworkPacket<StringDataSslConnection>();
  response.read(null, buffer, packetLength - 2);
 
  log.info(response.data(), "Response:[%s]"::formatted);