fix AmfLongString

pedroSG94 · Nov 9, 2023 · 2cdd1c1 · 2cdd1c1
1 parent 8f034fc
commit 2cdd1c1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/rtmp/src/main/java/com/pedro/rtmp/amf/v0/AmfLongString.kt b/rtmp/src/main/java/com/pedro/rtmp/amf/v0/AmfLongString.kt
@@ -28,15 +28,15 @@ import java.io.OutputStream
  */
 open class AmfLongString(var value: String = ""): AmfData() {
 
-  private var bodySize: Int = value.toByteArray(Charsets.UTF_8).size + 2
+  private var bodySize: Int = value.toByteArray(Charsets.UTF_8).size + 4
 
   @Throws(IOException::class)
   override fun readBody(input: InputStream) {
     //read value size as UInt32
     bodySize = input.readUInt32()
     //read value in UTF-8
     val bytes = ByteArray(bodySize)
-    bodySize += 2
+    bodySize += 4
     input.readUntil(bytes)
     value = String(bytes, Charsets.UTF_8)
   }
@@ -45,7 +45,7 @@ open class AmfLongString(var value: String = ""): AmfData() {
   override fun writeBody(output: OutputStream) {
     val bytes = value.toByteArray(Charsets.UTF_8)
     //write value size as UInt32. Value size not included
-    output.writeUInt32(bodySize - 2)
+    output.writeUInt32(bodySize - 4)
     //write value bytes in UTF-8
     output.write(bytes)
   }