From f34668b90df9d832c21a357f26ca514bb1f1e589 Mon Sep 17 00:00:00 2001
From: Vitor Pamplona <vitor@vitorpamplona.com>
Date: Sun, 19 Feb 2023 15:38:08 -0500
Subject: [PATCH] Moves processing of new events from IO to Default

---
 .../com/vitorpamplona/amethyst/service/relays/Client.kt   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt b/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt
index 21c4a288b..b8dea9cc8 100644
--- a/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt
+++ b/app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt
@@ -81,7 +81,7 @@ object Client: RelayPool.Listener {
     override fun onEvent(event: Event, subscriptionId: String, relay: Relay) {
         // Releases the Web thread for the new payload.
         // May need to add a processing queue if processing new events become too costly.
-        GlobalScope.launch(Dispatchers.IO) {
+        GlobalScope.launch(Dispatchers.Default) {
             listeners.forEach { it.onEvent(event, subscriptionId, relay) }
         }
     }
@@ -89,7 +89,7 @@ object Client: RelayPool.Listener {
     override fun onError(error: Error, subscriptionId: String, relay: Relay) {
         // Releases the Web thread for the new payload.
         // May need to add a processing queue if processing new events become too costly.
-        GlobalScope.launch(Dispatchers.IO) {
+        GlobalScope.launch(Dispatchers.Default) {
             listeners.forEach { it.onError(error, subscriptionId, relay) }
         }
     }
@@ -97,7 +97,7 @@ object Client: RelayPool.Listener {
     override fun onRelayStateChange(type: Relay.Type, relay: Relay, channel: String?) {
         // Releases the Web thread for the new payload.
         // May need to add a processing queue if processing new events become too costly.
-        GlobalScope.launch(Dispatchers.IO) {
+        GlobalScope.launch(Dispatchers.Default) {
             listeners.forEach { it.onRelayStateChange(type, relay, channel) }
         }
     }
@@ -105,7 +105,7 @@ object Client: RelayPool.Listener {
     override fun onSendResponse(eventId: String, success: Boolean, message: String, relay: Relay) {
         // Releases the Web thread for the new payload.
         // May need to add a processing queue if processing new events become too costly.
-        GlobalScope.launch(Dispatchers.IO) {
+        GlobalScope.launch(Dispatchers.Default) {
             listeners.forEach { it.onSendResponse(eventId, success, message, relay) }
         }
     }