updated PacketRegistry.java

Author: Daschi1

src/de/javasocketapi/core/OutputStreamThread.java

@@ -46,8 +46,9 @@ public void run() {
                     outputStream.write(bytes);
                     outputStream.flush();
                 }
+                Thread.sleep(0, 1);
             }
-        } catch (IOException e) {
+        } catch (IOException | InterruptedException e) {
             e.printStackTrace();
         }
     }

src/de/javasocketapi/core/PacketRegistry.java

@@ -1,25 +1,26 @@
 package de.javasocketapi.core;
 
-import org.reflections.Reflections;
-
 import java.util.ArrayList;
 import java.util.List;
 
-class PacketRegistry {
+public class PacketRegistry {
+
+    private static List<Class<? extends Packet>> registerdPackets = new ArrayList<>();
 
-    private static List<Class<? extends Packet>> registerdPackets;
+    static int indexOf(Class<? extends Packet> packetClass) {
+        return PacketRegistry.registerdPackets.indexOf(packetClass);
+    }
 
-    public static int indexOf(Class<? extends Packet> packetClass) {
-        return registerdPackets.indexOf(packetClass);
+    static Class<? extends Packet> get(int index) {
+        return PacketRegistry.registerdPackets.get(index);
     }
 
-    public static Class<? extends Packet> get(int index) {
-        return registerdPackets.get(index);
+    public static void registerPacket(Class<? extends Packet> packetClass) {
+        PacketRegistry.registerdPackets.add(packetClass);
     }
 
-    static {
-        Reflections reflections = new Reflections();
-        PacketRegistry.registerdPackets = new ArrayList<>(reflections.getSubTypesOf(Packet.class));
+    public static void registerPackets(List<Class<? extends Packet>> packetClasses) {
+        PacketRegistry.registerdPackets.addAll(packetClasses);
     }
 
 }