fix tests

Author: pedroSG94

common/src/test/java/com/pedro/common/ExtensionTest.kt

@@ -31,7 +31,7 @@ class ExtensionTest {
     val buffer = ByteBuffer.wrap(ByteArray(256) { 0x00 }.mapIndexed { index, byte -> index.toByte()  }.toByteArray())
     val offset = 4
     val minusLimit = 2
-    val info = MediaFrame.Info(4, buffer.remaining() - minusLimit, 0, false)
+    val info = MediaFrame.Info(4, buffer.remaining() - minusLimit, 0, false, 0)
     val result = buffer.removeInfo(info)
     assertEquals(buffer.capacity() - offset - minusLimit, result.remaining())
     assertEquals(offset.toByte(), result.get(0))

common/src/test/java/com/pedro/common/StreamBlockingQueueTest.kt

@@ -31,7 +31,7 @@ class StreamBlockingQueueTest {
   @Test
   fun checkItemLimit() {
     val queue = StreamBlockingQueue(50)
-    val frame = MediaFrame(ByteBuffer.wrap(byteArrayOf()), MediaFrame.Info(0, 0, 0L, false), MediaFrame.Type.VIDEO)
+    val frame = MediaFrame(ByteBuffer.wrap(byteArrayOf()), MediaFrame.Info(0, 0, 0L, false, 0), MediaFrame.Type.VIDEO)
     (0..60).forEach { i ->
       queue.trySend(frame)
     }

library/src/main/java/com/pedro/library/util/AndroidMuxerRecordController.kt

@@ -34,6 +34,7 @@ import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.Job
 import kotlinx.coroutines.channels.Channel
+import kotlinx.coroutines.isActive
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.runBlocking
 import java.io.FileDescriptor
@@ -159,11 +160,22 @@ class AndroidMuxerRecordController : BaseRecordController() {
   }
 
   override fun recordVideo(videoBuffer: ByteBuffer, videoInfo: MediaCodec.BufferInfo) {
+
     val info = videoInfo.toMediaFrameInfo()
     val i = updateFormat(info)
     muxerChannel?.trySend(MediaFrame(videoBuffer.clone(), i, MediaFrame.Type.VIDEO))
   }
 
+  var job: Job? = null
+
+  fun start() {
+    job = scope.launch {
+      while (isActive) {
+
+      }
+    }
+  }
+
   override fun recordAudio(audioBuffer: ByteBuffer, audioInfo: MediaCodec.BufferInfo) {
     val info = audioInfo.toMediaFrameInfo()
     val i = updateFormat(info)