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

Fix sendAndWaitForResponse never receiving a response

Browse Source
This commit is contained in:
greenart7c3
2025-10-03 13:20:56 -03:00
parent e12c52ec2c
commit beff7e60b7
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/accessories/NostrClientSendAndWaitExt.kt
+1 -2
View File
@@ -95,6 +95,7 @@ suspend fun INostrClient.sendAndWaitForResponse(
val receivedResults = mutableMapOf<NormalizedRelayUrl, Boolean>() val receivedResults = mutableMapOf<NormalizedRelayUrl, Boolean>()
// The withTimeout block will cancel the coroutine if the loop takes too long // The withTimeout block will cancel the coroutine if the loop takes too long
withTimeoutOrNull(timeoutInSeconds * 1000) { withTimeoutOrNull(timeoutInSeconds * 1000) {
send(event, relayList)
while (receivedResults.size < relayList.size) { while (receivedResults.size < relayList.size) {
val result = resultChannel.receive() val result = resultChannel.receive()
@@ -109,8 +110,6 @@ suspend fun INostrClient.sendAndWaitForResponse(
} }
} }
send(event, relayList)
val receivedResults = resultSubscription.await() val receivedResults = resultSubscription.await()
unsubscribe(subscription) unsubscribe(subscription)