Chunking: Honor buffer.hasRemaining() and otherwise release the buffe…

…r. (deepmedia#182)
natario1 · Feb 20, 2023 · f51a806 · f51a806
1 parent ccbcd50
commit f51a806
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/lib/src/main/java/com/otaliastudios/transcoder/internal/audio/chunks.kt b/lib/src/main/java/com/otaliastudios/transcoder/internal/audio/chunks.kt
@@ -25,8 +25,11 @@ internal class ChunkQueue(private val sampleRate: Int, private val channels: Int
     fun isEmpty() = queue.isEmpty()
 
     fun enqueue(buffer: ShortBuffer, timeUs: Long, timeStretch: Double, release: () -> Unit) {
-        require(buffer.hasRemaining())
-        queue.addLast(Chunk(buffer, timeUs, timeStretch, release))
+        if (buffer.hasRemaining()) {
+            queue.addLast(Chunk(buffer, timeUs, timeStretch, release))
+        } else {
+            release()
+        }
     }
 
     fun enqueueEos() {