add RecursiveStreamCodec

Author: LukynkaCZE

gradle.properties

@@ -1,2 +1,2 @@
 kotlin.code.style=official
-tide.version=3.0
+tide.version=3.2

src/main/kotlin/io/github/dockyardmc/tide/stream/RecursiveStreamCodec.kt

@@ -0,0 +1,17 @@
+package io.github.dockyardmc.tide.stream
+
+import io.netty.buffer.ByteBuf
+
+class RecursiveStreamCodec<T>(self: (StreamCodec<T>) -> StreamCodec<T>) : StreamCodec<T> {
+
+    val delegate = self.invoke(this)
+
+    override fun write(buffer: ByteBuf, value: T) {
+        delegate.write(buffer, value)
+    }
+
+    override fun read(buffer: ByteBuf): T {
+        return delegate.read(buffer)
+    }
+
+}

src/main/kotlin/io/github/dockyardmc/tide/stream/StreamCodec.kt

@@ -1,6 +1,8 @@
 package io.github.dockyardmc.tide.stream
 
+import io.github.dockyardmc.tide.codec.Codec
 import io.github.dockyardmc.tide.codec.CodecUtils
+import io.github.dockyardmc.tide.codec.RecursiveCodec
 import io.netty.buffer.ByteBuf
 import java.util.*
 
@@ -28,6 +30,7 @@ interface StreamCodec<T> {
         return ListStreamCodec<T>(this)
     }
 
+
     companion object {
         val UNIT = object : StreamCodec<Unit> {
 
@@ -173,6 +176,10 @@ interface StreamCodec<T> {
                 val leastSignificant = LONG.read(buffer)
                 return UUID(mostSignificant, leastSignificant)
             }
+
+            fun <T> recursive(self: (StreamCodec<T>) -> StreamCodec<T>): RecursiveStreamCodec<T> {
+                return RecursiveStreamCodec<T>(self)
+            }
         }
 
         val UUID_STRING = STRING.transform<UUID>({ uuid -> uuid.toString() }, { string -> java.util.UUID.fromString(string) })