@@ -14,7 +14,6 @@ import java.io.File
1414import java.io.FileOutputStream
1515import java.nio.ByteBuffer
1616import java.util.Base64
17- import java.util.concurrent.CompletableFuture
1817import kotlin.collections.List
1918import kotlin.collections.Map
2019import kotlinx.coroutines.*
@@ -40,7 +39,7 @@ public class FAudioTagger : FlutterPlugin, MethodCallHandler {
4039 lateinit var channel: MethodChannel
4140 lateinit var binaryMessenger: BinaryMessenger
4241 val eventChannels = HashMap <Number , BetterEventChannel >()
43- val streamCompleters = HashMap <Number , CompletableFuture <Number >>()
42+ val streamCompleters = HashMap <Number , CompletableDeferred <Number >>()
4443 lateinit var context: Context
4544
4645 companion object {
@@ -145,13 +144,13 @@ public class FAudioTagger : FlutterPlugin, MethodCallHandler {
145144 val eventChannel = eventChannels.get(streamKey)!!
146145 val eventChannelIndices = BetterEventChannel (binaryMessenger, " faudiotagger/stream/" + streamKey + " .index" )
147146
148- streamCompleters.set(streamKey, CompletableFuture <Number >())
147+ streamCompleters.set(streamKey, CompletableDeferred <Number >())
149148 result.success(streamKey)
150149
151150 CoroutineScope (Dispatchers .IO ).launch {
152151 _addLogsUser ()
153152 // waiting for confirmation before posting to stream
154- streamCompleters.get(streamKey)!! .get ()
153+ streamCompleters.get(streamKey)!! .await ()
155154 var index: Int = - 1
156155 for (p in paths) {
157156 var map = HashMap <String , Any >()
0 commit comments