add new funtion utils

Author: JavaSaBr

build.gradle

@@ -8,7 +8,7 @@ buildscript {
     }
 }
 
-rootProject.version = '9.9.0'
+rootProject.version = '9.10.0'
 group = 'com.spaceshift'
 
 allprojects {

rlib-common/src/main/java/com/ss/rlib/common/function/Functions.java

@@ -0,0 +1,70 @@
+package com.ss.rlib.common.function;
+
+import org.jetbrains.annotations.NotNull;
+
+import java.util.function.Predicate;
+import java.util.function.Supplier;
+
+public class Functions {
+
+    public static class Predicates {
+
+        public static @NotNull Predicate<Boolean> isTrue() {
+
+            return bool -> bool;
+        }
+
+        public static @NotNull Predicate<Boolean> ifTrue(@NotNull Runnable task) {
+
+            return bool -> {
+
+                if (bool) {
+                    task.run();
+                }
+
+                return true;
+            };
+        }
+
+        public static @NotNull Predicate<Boolean> throwIfTrue(@NotNull Supplier<? extends RuntimeException> factory) {
+
+            return bool -> {
+
+                if (bool) {
+                    throw factory.get();
+                }
+
+                return true;
+            };
+        }
+
+        public static @NotNull Predicate<Boolean> isFalse() {
+
+            return bool -> !bool;
+        }
+
+        public static @NotNull Predicate<Boolean> ifFalse(@NotNull Runnable task) {
+
+            return bool -> {
+
+                if (!bool) {
+                    task.run();
+                }
+
+                return true;
+            };
+        }
+
+        public static @NotNull Predicate<Boolean> throwIfFalse(@NotNull Supplier<? extends RuntimeException> factory) {
+
+            return bool -> {
+
+                if (!bool) {
+                    throw factory.get();
+                }
+
+                return true;
+            };
+        }
+    }
+}

rlib-network/src/main/java/com/ss/rlib/network/packet/impl/AbstractPacketReader.java

@@ -278,13 +278,7 @@ else if (packetLength > tempPendingBuffer.capacity()) {
 
             if (packet != null) {
                 LOGGER.debug(packet, pck -> "Created instance of packet to read data: " + pck);
-
-                if (packet.read(connection, bufferToRead, dataLength)) {
-                    readPacketHandler.accept(packet);
-                } else {
-                    LOGGER.error("Packet " + packet + " was read incorrectly");
-                }
-
+                readAndHandlePacket(bufferToRead, dataLength, packet);
                 LOGGER.debug(packet, pck -> "Finished reading data of packet: " + pck);
                 readPackets++;
             } else {
@@ -319,6 +313,14 @@ else if (packetLength > tempPendingBuffer.capacity()) {
         return readPackets;
     }
 
+    protected void readAndHandlePacket(@NotNull ByteBuffer bufferToRead, int dataLength, @NotNull R packet) {
+        if (packet.read(connection, bufferToRead, dataLength)) {
+            readPacketHandler.accept(packet);
+        } else {
+            LOGGER.error("Packet " + packet + " was read incorrectly");
+        }
+    }
+
     /**
      * Check buffer's data.
      *