nick/amethyst
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

When broadcasting privately, avoids keeping the connection open for other activities.

Browse Source
This commit is contained in:
Vitor Pamplona
2024-06-05 08:33:11 -04:00
parent ae418f9d45
commit d9cffa87ef
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/src/main/java/com/vitorpamplona/amethyst/service/relays/Client.kt
+1 -1
View File
@@ -165,7 +165,7 @@ object Client : RelayPool.Listener {
checkNotInMainThread() checkNotInMainThread()
relayList.forEach { relayUrl -> relayList.forEach { relayUrl ->
RelayPool.getOrCreateRelay(relayUrl, setOf(FeedType.PRIVATE_DMS), { }) { RelayPool.getOrCreateRelay(relayUrl, emptySet(), { }) {
it.sendOverride(signedEvent) it.sendOverride(signedEvent)
} }
} }
app/src/main/java/com/vitorpamplona/amethyst/service/relays/RelayPool.kt
+2 -1
View File
@@ -91,6 +91,7 @@ object RelayPool : Relay.Listener {
feedTypes: Set<FeedType>?, feedTypes: Set<FeedType>?,
onConnected: (Relay) -> Unit, onConnected: (Relay) -> Unit,
onDone: (() -> Unit)?, onDone: (() -> Unit)?,
timeout: Long = 60000,
) { ) {
val relay = Relay(url, true, true, feedTypes ?: emptySet()) val relay = Relay(url, true, true, feedTypes ?: emptySet())
addRelay(relay) addRelay(relay)
@@ -103,7 +104,7 @@ object RelayPool : Relay.Listener {
onConnected(relay) onConnected(relay)
GlobalScope.launch(Dispatchers.IO) { GlobalScope.launch(Dispatchers.IO) {
delay(60000) // waits for a reply delay(timeout) // waits for a reply
relay.disconnect() relay.disconnect()
removeRelay(relay) removeRelay(relay)