Fix #1 & concurrency issue

 - Updated docs

Author: XIAYM-gh

README.md

@@ -226,11 +226,17 @@ public record MyPayloadTwo(Player player) implements Payload {
 
     @PayloadDeserializer
     public static MyPayloadTwo deserialize(ByteBuf buf) {
-        UUID uuid = SerializationImpl.getInternalDeserializer(UUID.class).apply(buf);
-        Player player = Bukkit.getPlayer(uuid);
-        assert player != null;
-
-        return new MyPayloadTwo(player);
+        try {
+            UUID uuid = SerializationImpl.getInternalDeserializer(UUID.class).apply(buf);
+            Player player = Bukkit.getPlayer(uuid);
+            assert player != null;
+
+            return new MyPayloadTwo(player);
+        } catch (RuntimeException ex) {
+            // This is required due to we're using an pooled buffer internally
+            buf.release();
+            throw ex;
+        }
     }
 }
 ```

build.gradle

@@ -6,7 +6,7 @@ plugins {
 }
 
 group = 'top.nlrdev'
-version = '0.0.2-SNAPSHOT'
+version = rootProject.plugin_version
 
 subprojects {
     apply plugin: 'java'

core/build.gradle

@@ -87,7 +87,10 @@ tasks {
 }
 
 processResources {
-    def props = [version: version]
+    def props = [
+            version: version + (Integer.parseInt(rootProject.hotfix_number) > 0 ? '+hotfix.' + rootProject.hotfix_number : '')
+    ]
+
     inputs.properties props
     filteringCharset = 'UTF-8'
     filesMatching('plugin.yml') {

core/src/main/java/top/nlrdev/payloadlib/serialization/SerializationImpl.java

@@ -21,13 +21,14 @@
 import java.lang.invoke.VarHandle;
 import java.util.HashMap;
 import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.BiConsumer;
 import java.util.function.Function;
 
 public class SerializationImpl {
     private static final HashMap<Class<?>, BiConsumer<ByteBuf, ?>> INTERNAL_SERIALIZERS = new HashMap<>();
     private static final HashMap<Class<?>, Function<ByteBuf, ?>> INTERNAL_DESERIALIZERS = new HashMap<>();
-    private static final HashMap<Class<?>, TypeBinding<?>> TYPE_BINDINGS = new HashMap<>();
+    private static final ConcurrentHashMap<Class<?>, TypeBinding<?>> TYPE_BINDINGS = new ConcurrentHashMap<>();
 
     // TODO: Collection, Map, Optional, Nullable, Bit Set, Enum Set, NBT(WTF?), Registry,
     // TODO: BlockHitResult
@@ -162,7 +163,7 @@ public static <T extends Payload> T deserialize(@NotNull Identifier id, @NotNull
 
             TypeBinding<?> customBinding = TYPE_BINDINGS.get(varType);
             if (customBinding != null) {
-                customBinding.deserializer().apply(buf);
+                deserialized[i] = customBinding.deserializer().apply(buf);
                 continue;
             }
 

gradle.properties

@@ -1 +1,5 @@
-org.gradle.parallel=true
+org.gradle.parallel=true
+org.gradle.configureondemand=true
+
+plugin_version=0.0.2-SNAPSHOT
+hotfix_number=1