small chnages

LuftVerbot · Sep 18, 2024 · 09e36df · 09e36df
1 parent ae9550a
commit 09e36df
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/ext/src/main/java/dev/brahmkshatriya/echo/extension/Utils.kt b/ext/src/main/java/dev/brahmkshatriya/echo/extension/Utils.kt
@@ -77,7 +77,7 @@ fun String.toMD5(): String {
 
 @Suppress("NewApi")
 @OptIn(ExperimentalCoroutinesApi::class)
-fun getByteStreamAudio(
+suspend fun getByteStreamAudio(
     scope: CoroutineScope,
     streamable: Streamable,
     client: OkHttpClient
@@ -97,11 +97,11 @@ fun getByteStreamAudio(
         .build()
 
     val byteChannel = ByteChannel()
+    val response = clientWithTimeouts.newCall(request).executeAsync()
 
     scope.launch(Dispatchers.IO) {
         try {
-            clientWithTimeouts.newCall(request).executeAsync().use { response ->
-                response.body.byteStream().buffered().use { byteStream ->
+                response.body.byteStream().use { byteStream ->
                     try {
                         var totalBytesRead = 0L
                         var counter = 0
@@ -145,7 +145,6 @@ fun getByteStreamAudio(
                         byteChannel.close()
                     }
                 }
-            }
         } catch (e: IOException) {
             println("Exception during decryption or streaming: ${e.message}")
         }