From 1a038b235575d941d484009b32f032f48cb165da Mon Sep 17 00:00:00 2001
From: Hugh Daschbach <hugh@ccss.com>
Date: Sat, 20 Aug 2022 17:04:54 -0700
Subject: [PATCH] CommandBus: replace deprecated implementation.

Convert CommandBus from deprecated BroadcastChannel to a SharedFlow.
---
 app/src/main/java/audio/funkwhale/ffa/FFA.kt       | 2 --
 app/src/main/java/audio/funkwhale/ffa/utils/Bus.kt | 6 ++++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/app/src/main/java/audio/funkwhale/ffa/FFA.kt b/app/src/main/java/audio/funkwhale/ffa/FFA.kt
index bae0713..cdac362 100644
--- a/app/src/main/java/audio/funkwhale/ffa/FFA.kt
+++ b/app/src/main/java/audio/funkwhale/ffa/FFA.kt
@@ -6,7 +6,6 @@ import androidx.appcompat.app.AppCompatDelegate
 import audio.funkwhale.ffa.koin.authModule
 import audio.funkwhale.ffa.koin.exoplayerModule
 import audio.funkwhale.ffa.utils.AppContext
-import audio.funkwhale.ffa.utils.Command
 import audio.funkwhale.ffa.utils.FFACache
 import audio.funkwhale.ffa.utils.Request
 import com.preference.PowerPreference
@@ -26,7 +25,6 @@ class FFA : Application() {
 
   var defaultExceptionHandler: Thread.UncaughtExceptionHandler? = null
 
-  val commandBus: BroadcastChannel<Command> = BroadcastChannel(10)
   val requestBus: BroadcastChannel<Request> = BroadcastChannel(10)
 
   override fun onCreate() {
diff --git a/app/src/main/java/audio/funkwhale/ffa/utils/Bus.kt b/app/src/main/java/audio/funkwhale/ffa/utils/Bus.kt
index 8820bc5..22d368d 100644
--- a/app/src/main/java/audio/funkwhale/ffa/utils/Bus.kt
+++ b/app/src/main/java/audio/funkwhale/ffa/utils/Bus.kt
@@ -86,13 +86,15 @@ object EventBus {
 }
 
 object CommandBus {
+  private var _commands = MutableSharedFlow<Command>()
+  var commands = _commands.asSharedFlow()
   fun send(command: Command) {
     GlobalScope.launch(IO) {
-      FFA.get().commandBus.trySend(command).isSuccess
+    _commands.emit(command)
     }
   }
 
-  fun get() = FFA.get().commandBus.asFlow()
+  fun get() = commands
 }
 
 object RequestBus {