diff --git a/src/Main.java b/src/Main.java
index dfec8d3..1c41ace 100644
--- a/src/Main.java
+++ b/src/Main.java
@@ -1,6 +1,9 @@
-import net.tofvesson.math.MathSerializer;
+import net.tofvesson.annotation.SyncedVar;
+import net.tofvesson.data.DiffTracked;
+import net.tofvesson.data.DiffTrackedArray;
+import net.tofvesson.data.SyncHandler;
+import net.tofvesson.serializers.MathSerializer;
 import net.tofvesson.math.Vector3;
-import net.tofvesson.networking.*;
 
 public class Main {
     @SyncedVar("NonNegative")
@@ -33,7 +36,6 @@ public class Main {
     public static void main(String[] args){
         Main testObject = new Main();
 
-        SyncHandler.Companion.registerSerializer(MathSerializer.Companion.getSingleton());
         SyncHandler sync = new SyncHandler();
         sync.registerSyncObject(testObject);
         sync.registerSyncObject(Main.class);
diff --git a/src/net/tofvesson/networking/NoUpwardCascade.kt b/src/net/tofvesson/annotation/NoUpwardCascade.kt
similarity index 74%
rename from src/net/tofvesson/networking/NoUpwardCascade.kt
rename to src/net/tofvesson/annotation/NoUpwardCascade.kt
index 70d4d5c..1f46b65 100644
--- a/src/net/tofvesson/networking/NoUpwardCascade.kt
+++ b/src/net/tofvesson/annotation/NoUpwardCascade.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.annotation
 
 /**
  * Prevents SyncedVar system from syncing superclasses
diff --git a/src/net/tofvesson/networking/SyncedVar.kt b/src/net/tofvesson/annotation/SyncedVar.kt
similarity index 95%
rename from src/net/tofvesson/networking/SyncedVar.kt
rename to src/net/tofvesson/annotation/SyncedVar.kt
index 2647f91..8375dc9 100644
--- a/src/net/tofvesson/networking/SyncedVar.kt
+++ b/src/net/tofvesson/annotation/SyncedVar.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.annotation
 
 import net.tofvesson.reflect.*
 
@@ -31,7 +31,7 @@ enum class SyncFlag {
 
         fun createFlag(name: String): SyncFlag {
             // Do duplication check
-            if(getByName(name)!=null) throw IllegalArgumentException("Flag \"$name\" is already registered!")
+            if(getByName(name) !=null) throw IllegalArgumentException("Flag \"$name\" is already registered!")
 
             // Get unsafe
             val unsafe = getUnsafe()
diff --git a/src/net/tofvesson/data/ArrayExtensions.kt b/src/net/tofvesson/data/ArrayExtensions.kt
new file mode 100644
index 0000000..eadcec5
--- /dev/null
+++ b/src/net/tofvesson/data/ArrayExtensions.kt
@@ -0,0 +1,10 @@
+package net.tofvesson.data
+
+fun ByteArray.readBits(index: Int, bitCount: Int, bitOffset: Int = 0): Int {
+    var result = 0
+    for(i in 0 until bitCount)
+        result = result or readBit(index, bitOffset+i)
+    return result
+}
+
+fun ByteArray.readBit(index: Int, bitOffset: Int = 0) = (this[index + (bitOffset ushr 3)].toInt() ushr (bitOffset and 7)) and 1
\ No newline at end of file
diff --git a/src/net/tofvesson/networking/DiffTracked.kt b/src/net/tofvesson/data/DiffTracked.kt
similarity index 92%
rename from src/net/tofvesson/networking/DiffTracked.kt
rename to src/net/tofvesson/data/DiffTracked.kt
index 7c9be7e..ad39f72 100644
--- a/src/net/tofvesson/networking/DiffTracked.kt
+++ b/src/net/tofvesson/data/DiffTracked.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.data
 
 import java.util.*
 
diff --git a/src/net/tofvesson/networking/DiffTrackedArray.kt b/src/net/tofvesson/data/DiffTrackedArray.kt
similarity index 96%
rename from src/net/tofvesson/networking/DiffTrackedArray.kt
rename to src/net/tofvesson/data/DiffTrackedArray.kt
index 6287a36..e89fbd1 100644
--- a/src/net/tofvesson/networking/DiffTrackedArray.kt
+++ b/src/net/tofvesson/data/DiffTrackedArray.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.data
 
 class DiffTrackedArray<T>(val elementType: Class<T>, val size: Int, gen: (Int) -> T) {
 
diff --git a/src/net/tofvesson/networking/Holder.kt b/src/net/tofvesson/data/Holder.kt
similarity index 80%
rename from src/net/tofvesson/networking/Holder.kt
rename to src/net/tofvesson/data/Holder.kt
index 4964ead..ea80f95 100644
--- a/src/net/tofvesson/networking/Holder.kt
+++ b/src/net/tofvesson/data/Holder.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.data
 
 data class Holder(var value: Any?){
     companion object {
diff --git a/src/net/tofvesson/networking/ReadBuffer.kt b/src/net/tofvesson/data/ReadBuffer.kt
similarity index 97%
rename from src/net/tofvesson/networking/ReadBuffer.kt
rename to src/net/tofvesson/data/ReadBuffer.kt
index 3dc9c62..5d40a41 100644
--- a/src/net/tofvesson/networking/ReadBuffer.kt
+++ b/src/net/tofvesson/data/ReadBuffer.kt
@@ -1,6 +1,7 @@
-package net.tofvesson.networking
+package net.tofvesson.data
 
-import net.tofvesson.math.collapseLowerByte
+import net.tofvesson.exception.InsufficientCapacityException
+import net.tofvesson.math.*
 import java.nio.ByteBuffer
 
 @Suppress("MemberVisibilityCanBePrivate", "unused")
diff --git a/src/net/tofvesson/networking/Serializer.kt b/src/net/tofvesson/data/Serializer.kt
similarity index 94%
rename from src/net/tofvesson/networking/Serializer.kt
rename to src/net/tofvesson/data/Serializer.kt
index de5e040..e92d42d 100644
--- a/src/net/tofvesson/networking/Serializer.kt
+++ b/src/net/tofvesson/data/Serializer.kt
@@ -1,5 +1,7 @@
-package net.tofvesson.networking
+package net.tofvesson.data
 
+import net.tofvesson.annotation.SyncFlag
+import net.tofvesson.exception.UnsupportedTypeException
 import java.lang.reflect.Field
 import java.util.*
 
diff --git a/src/net/tofvesson/networking/SyncHandler.kt b/src/net/tofvesson/data/SyncHandler.kt
similarity index 90%
rename from src/net/tofvesson/networking/SyncHandler.kt
rename to src/net/tofvesson/data/SyncHandler.kt
index bdfa3b3..e5f9579 100644
--- a/src/net/tofvesson/networking/SyncHandler.kt
+++ b/src/net/tofvesson/data/SyncHandler.kt
@@ -1,6 +1,14 @@
-package net.tofvesson.networking
+package net.tofvesson.data
 
+import net.tofvesson.annotation.NoUpwardCascade
+import net.tofvesson.annotation.SyncFlag
+import net.tofvesson.annotation.SyncedVar
+import net.tofvesson.exception.UnsupportedTypeException
 import net.tofvesson.reflect.access
+import net.tofvesson.serializers.DiffTrackedSerializer
+import net.tofvesson.serializers.MathSerializer
+import net.tofvesson.serializers.PrimitiveArraySerializer
+import net.tofvesson.serializers.PrimitiveSerializer
 import java.lang.reflect.Field
 import java.nio.ByteBuffer
 import java.security.NoSuchAlgorithmException
@@ -20,6 +28,7 @@ class SyncHandler(private val permissiveMismatchCheck: Boolean = false) {
             serializers.add(PrimitiveSerializer.singleton)
             serializers.add(PrimitiveArraySerializer.singleton)
             serializers.add(DiffTrackedSerializer.singleton)
+            serializers.add(MathSerializer.singleton)
         }
 
         fun registerSerializer(serializer: Serializer) {
@@ -121,7 +130,7 @@ class SyncHandler(private val permissiveMismatchCheck: Boolean = false) {
     private fun computeObjectSize(value: Any, writeState: WriteState) = computeTypeSize(value.javaClass, value, writeState)
     private fun computeClassSize(value: Class<*>, writeState: WriteState) = computeTypeSize(value, null, writeState)
     private fun computeTypeSize(type: Class<*>, value: Any?, writeState: WriteState) {
-        for(field in collectSyncable(type, value==null))
+        for(field in collectSyncable(type, value == null))
             getCompatibleSerializer(field.access().type)
                     .computeSize(field, SyncFlag.parse(field.getAnnotation(SyncedVar::class.java).value), value, writeState)
     }
@@ -129,7 +138,7 @@ class SyncHandler(private val permissiveMismatchCheck: Boolean = false) {
     private fun readObject(value: Any, writeBuffer: WriteBuffer) = readType(value.javaClass, value, writeBuffer)
     private fun readClass(value: Class<*>, writeBuffer: WriteBuffer) = readType(value, null, writeBuffer)
     private fun readType(type: Class<*>, value: Any?, writeBuffer: WriteBuffer) {
-        for(field in collectSyncable(type, value==null))
+        for(field in collectSyncable(type, value == null))
             getCompatibleSerializer(field.type)
                     .serialize(field, SyncFlag.parse(field.getAnnotation(SyncedVar::class.java).value), value, writeBuffer)
     }
@@ -137,7 +146,7 @@ class SyncHandler(private val permissiveMismatchCheck: Boolean = false) {
     private fun writeObject(value: Any, readBuffer: ReadBuffer) = writeType(value.javaClass, value, readBuffer)
     private fun writeClass(value: Class<*>, readBuffer: ReadBuffer) = writeType(value, null, readBuffer)
     private fun writeType(type: Class<*>, value: Any?, readBuffer: ReadBuffer) {
-        for(field in collectSyncable(type, value==null))
+        for(field in collectSyncable(type, value == null))
             getCompatibleSerializer(field.type)
                     .deserialize(field, SyncFlag.parse(field.getAnnotation(SyncedVar::class.java).value), value, readBuffer)
     }
diff --git a/src/net/tofvesson/networking/WriteBuffer.kt b/src/net/tofvesson/data/WriteBuffer.kt
similarity index 97%
rename from src/net/tofvesson/networking/WriteBuffer.kt
rename to src/net/tofvesson/data/WriteBuffer.kt
index b69360b..224a991 100644
--- a/src/net/tofvesson/networking/WriteBuffer.kt
+++ b/src/net/tofvesson/data/WriteBuffer.kt
@@ -1,7 +1,7 @@
-package net.tofvesson.networking
+package net.tofvesson.data
 
-import net.tofvesson.math.collapseLowerByte
-import net.tofvesson.math.toNumber
+import net.tofvesson.exception.InsufficientCapacityException
+import net.tofvesson.math.*
 import java.nio.ByteBuffer
 import kotlin.experimental.and
 import kotlin.experimental.or
diff --git a/src/net/tofvesson/networking/WriteState.kt b/src/net/tofvesson/data/WriteState.kt
similarity index 68%
rename from src/net/tofvesson/networking/WriteState.kt
rename to src/net/tofvesson/data/WriteState.kt
index 8c22f49..63a19fc 100644
--- a/src/net/tofvesson/networking/WriteState.kt
+++ b/src/net/tofvesson/data/WriteState.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.data
 
 import net.tofvesson.math.collapseLowerByte
 
@@ -10,9 +10,9 @@ data class WriteState(private var _bytes: Int, private var _bits: Int, private v
     var header: Int = _header
         private set
 
-    fun registerBytes(bytes: Int): WriteState  { this.bytes  += bytes;  return this }
-    fun registerBits(bits: Int) : WriteState   { this.bits   += bits;   return this }
-    fun registerHeader(header: Int): WriteState{ this.header += header; return this }
+    fun registerBytes(bytes: Int): WriteState { this.bytes  += bytes;  return this }
+    fun registerBits(bits: Int) : WriteState { this.bits   += bits;   return this }
+    fun registerHeader(header: Int): WriteState { this.header += header; return this }
 
     fun computeRequiredBytes(additionalBytes: Int = 0, additionalBits: Int = 0) =
             bytes + additionalBytes + computeBitFieldOffset(additionalBits)
diff --git a/src/net/tofvesson/networking/InsufficientCapacityException.kt b/src/net/tofvesson/exception/InsufficientCapacityException.kt
similarity index 92%
rename from src/net/tofvesson/networking/InsufficientCapacityException.kt
rename to src/net/tofvesson/exception/InsufficientCapacityException.kt
index de26cd2..eaa3133 100644
--- a/src/net/tofvesson/networking/InsufficientCapacityException.kt
+++ b/src/net/tofvesson/exception/InsufficientCapacityException.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.exception
 
 class InsufficientCapacityException: RuntimeException {
     constructor() : super()
diff --git a/src/net/tofvesson/networking/MismatchedFlagException.kt b/src/net/tofvesson/exception/MismatchedFlagException.kt
similarity index 92%
rename from src/net/tofvesson/networking/MismatchedFlagException.kt
rename to src/net/tofvesson/exception/MismatchedFlagException.kt
index f8514b4..561037a 100644
--- a/src/net/tofvesson/networking/MismatchedFlagException.kt
+++ b/src/net/tofvesson/exception/MismatchedFlagException.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.exception
 
 class MismatchedFlagException: RuntimeException {
     constructor() : super()
diff --git a/src/net/tofvesson/networking/UnsupportedTypeException.kt b/src/net/tofvesson/exception/UnsupportedTypeException.kt
similarity index 92%
rename from src/net/tofvesson/networking/UnsupportedTypeException.kt
rename to src/net/tofvesson/exception/UnsupportedTypeException.kt
index a85a256..df457c6 100644
--- a/src/net/tofvesson/networking/UnsupportedTypeException.kt
+++ b/src/net/tofvesson/exception/UnsupportedTypeException.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.exception
 
 class UnsupportedTypeException: RuntimeException {
     constructor() : super()
diff --git a/src/net/tofvesson/networking/Arithmetic.kt b/src/net/tofvesson/math/Arithmetic.kt
similarity index 99%
rename from src/net/tofvesson/networking/Arithmetic.kt
rename to src/net/tofvesson/math/Arithmetic.kt
index c115bb6..46912d0 100644
--- a/src/net/tofvesson/networking/Arithmetic.kt
+++ b/src/net/tofvesson/math/Arithmetic.kt
@@ -1,4 +1,4 @@
-package net.tofvesson.networking
+package net.tofvesson.math
 
 import java.nio.ByteBuffer
 import kotlin.experimental.or
diff --git a/src/net/tofvesson/math/Vector3.kt b/src/net/tofvesson/math/Vector3.kt
index 382bc9c..92b137e 100644
--- a/src/net/tofvesson/math/Vector3.kt
+++ b/src/net/tofvesson/math/Vector3.kt
@@ -1,6 +1,6 @@
 package net.tofvesson.math
 
-import net.tofvesson.networking.DiffTracked
+import net.tofvesson.data.DiffTracked
 
 class Vector3(xPos: Float, yPos: Float, zPos: Float) {
 
diff --git a/src/net/tofvesson/networking/ReliableUDP.kt b/src/net/tofvesson/networking/ReliableUDP.kt
new file mode 100644
index 0000000..51c5dbb
--- /dev/null
+++ b/src/net/tofvesson/networking/ReliableUDP.kt
@@ -0,0 +1,64 @@
+package net.tofvesson.networking
+
+import net.tofvesson.reflect.access
+import java.net.DatagramPacket
+import java.net.DatagramSocket
+import java.net.InetAddress
+import java.util.concurrent.atomic.AtomicBoolean
+
+class ReliableUDP(address: InetAddress, port: Short, private val onAccept: (ByteArray, Int, Int) -> Unit, private val automaticAccept: Boolean, acceptTimeout: Long = 10L) {
+
+    private enum class PacketType(val bits: Int = (javaClass.getDeclaredField("\$VALUES").access().get(null) as Array<*>).indexOf(this)) {
+        DATA, ACK, FIN;
+        companion object {
+            val fieldSize = (Math.log((javaClass.getDeclaredField("\$VALUES").access().get(null) as Array<*>).size.toDouble()) / Math.log(2.0)).toInt() + 1
+        }
+    }
+
+    private var socket = DatagramSocket()
+    private val sync: Thread? = if(automaticAccept) Thread { acceptLoop() } else null
+    private val stop = AtomicBoolean(false)
+    private var finInitiated = false
+    private val packet = DatagramPacket(ByteArray(socket.receiveBufferSize), socket.receiveBufferSize)
+
+    init {
+        socket.connect(address, port.toInt())
+        socket.soTimeout = 0
+        sync?.start()
+    }
+
+    private fun acceptLoop(){
+        while(synchronized(stop){!stop.get()}){
+            accept()
+            if(packet.length==0) continue // Drop empty packets
+            val packetType = PacketType.values()[packet.data[0].toInt()]
+            when(packetType){
+                PacketType.DATA -> {
+
+                }
+
+                PacketType.ACK -> {
+
+                }
+
+                PacketType.FIN -> {
+
+                }
+            }
+        }
+    }
+
+    fun accept(){
+        if(automaticAccept && Thread.currentThread() != sync)
+            throw IllegalThreadStateException("Current thread isn't setup to accept datagram packets")
+        socket.receive(packet)
+    }
+
+    fun send(){
+        if(finInitiated) throw IllegalStateException("Cannot send message after connection is closed!")
+    }
+
+    fun _send(){
+
+    }
+}
\ No newline at end of file
diff --git a/src/net/tofvesson/networking/DiffTrackedSerializer.kt b/src/net/tofvesson/serializers/DiffTrackedSerializer.kt
similarity index 97%
rename from src/net/tofvesson/networking/DiffTrackedSerializer.kt
rename to src/net/tofvesson/serializers/DiffTrackedSerializer.kt
index bfef8e4..7669282 100644
--- a/src/net/tofvesson/networking/DiffTrackedSerializer.kt
+++ b/src/net/tofvesson/serializers/DiffTrackedSerializer.kt
@@ -1,5 +1,7 @@
-package net.tofvesson.networking
+package net.tofvesson.serializers
 
+import net.tofvesson.annotation.SyncFlag
+import net.tofvesson.data.*
 import java.lang.reflect.Field
 
 class DiffTrackedSerializer private constructor(): Serializer(arrayOf(
diff --git a/src/net/tofvesson/math/MathSerializer.kt b/src/net/tofvesson/serializers/MathSerializer.kt
similarity index 95%
rename from src/net/tofvesson/math/MathSerializer.kt
rename to src/net/tofvesson/serializers/MathSerializer.kt
index faff4be..541e1a0 100644
--- a/src/net/tofvesson/math/MathSerializer.kt
+++ b/src/net/tofvesson/serializers/MathSerializer.kt
@@ -1,6 +1,9 @@
-package net.tofvesson.math
+package net.tofvesson.serializers
 
-import net.tofvesson.networking.*
+import net.tofvesson.annotation.SyncFlag
+import net.tofvesson.data.*
+import net.tofvesson.exception.MismatchedFlagException
+import net.tofvesson.math.*
 import net.tofvesson.reflect.access
 import java.lang.reflect.Field
 
@@ -102,13 +105,13 @@ class MathSerializer: Serializer(arrayOf(
                         if(nn || pc){
                             var track = 0
                             flags = Array(flags.size - resize){
-                                if(flags[track]==SyncFlag.NonNegative && nn){
-                                    if(flags[++track]==SyncFlag.NoCompress && pc)
+                                if(flags[track]== SyncFlag.NonNegative && nn){
+                                    if(flags[++track]== SyncFlag.NoCompress && pc)
                                     flags[++track]
                                     else flags[track]
                                 }
-                                else if(flags[track]==SyncFlag.NoCompress && nn){
-                                    if(flags[++track]==SyncFlag.NonNegative && pc)
+                                else if(flags[track]== SyncFlag.NoCompress && nn){
+                                    if(flags[++track]== SyncFlag.NonNegative && pc)
                                         flags[++track]
                                     else flags[track]
                                 }else flags[track]
diff --git a/src/net/tofvesson/networking/PrimitiveArraySerializer.kt b/src/net/tofvesson/serializers/PrimitiveArraySerializer.kt
similarity index 99%
rename from src/net/tofvesson/networking/PrimitiveArraySerializer.kt
rename to src/net/tofvesson/serializers/PrimitiveArraySerializer.kt
index ae140f9..b786b81 100644
--- a/src/net/tofvesson/networking/PrimitiveArraySerializer.kt
+++ b/src/net/tofvesson/serializers/PrimitiveArraySerializer.kt
@@ -1,5 +1,7 @@
-package net.tofvesson.networking
+package net.tofvesson.serializers
 
+import net.tofvesson.annotation.SyncFlag
+import net.tofvesson.data.*
 import java.lang.reflect.Field
 
 @Suppress("MemberVisibilityCanBePrivate")
diff --git a/src/net/tofvesson/networking/PrimitiveSerializers.kt b/src/net/tofvesson/serializers/PrimitiveSerializers.kt
similarity index 96%
rename from src/net/tofvesson/networking/PrimitiveSerializers.kt
rename to src/net/tofvesson/serializers/PrimitiveSerializers.kt
index f686725..87587c7 100644
--- a/src/net/tofvesson/networking/PrimitiveSerializers.kt
+++ b/src/net/tofvesson/serializers/PrimitiveSerializers.kt
@@ -1,5 +1,11 @@
-package net.tofvesson.networking
+package net.tofvesson.serializers
 
+import net.tofvesson.annotation.SyncFlag
+import net.tofvesson.data.ReadBuffer
+import net.tofvesson.data.Serializer
+import net.tofvesson.data.WriteBuffer
+import net.tofvesson.data.WriteState
+import net.tofvesson.math.*
 import net.tofvesson.reflect.*
 import java.lang.reflect.Field