fix(Android): Sync recording thread start.

fixes #435
llfbandit · Dec 23, 2024 · 4c4ba96 · 4c4ba96
1 parent 6571dcd
commit 4c4ba96
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/record_android/android/src/main/kotlin/com/llfbandit/record/record/recorder/RecordThread.kt b/record_android/android/src/main/kotlin/com/llfbandit/record/record/recorder/RecordThread.kt
@@ -14,6 +14,7 @@ import com.llfbandit.record.record.format.Format
 import com.llfbandit.record.record.format.OpusFormat
 import com.llfbandit.record.record.format.PcmFormat
 import com.llfbandit.record.record.format.WaveFormat
+import java.util.concurrent.CountDownLatch
 import java.util.concurrent.Executors
 import java.util.concurrent.Semaphore
 import java.util.concurrent.atomic.AtomicBoolean
@@ -84,6 +85,8 @@ class RecordThread(
     fun getAmplitude(): Double = mPcmReader?.getAmplitude() ?: -160.0
 
     fun startRecording() {
+        val startLatch = CountDownLatch(1)
+
         mExecutorService.execute {
             try {
                 val format = selectFormat()
@@ -97,6 +100,8 @@ class RecordThread(
 
                 recordState()
 
+                startLatch.countDown()
+
                 while (isRecording()) {
                     if (isPaused()) {
                         mIsPausedSem.acquire()
@@ -112,9 +117,12 @@ class RecordThread(
             } catch (ex: Exception) {
                 recorderListener.onFailure(ex)
             } finally {
+                startLatch.countDown()
                 stopAndRelease()
             }
         }
+
+        startLatch.await()
     }
 
     private fun stopAndRelease() {