summaryrefslogtreecommitdiff
path: root/wallet/src/main/java/net/taler/wallet/exchanges
diff options
context:
space:
mode:
authorTorsten Grote <t@grobox.de>2023-02-22 14:29:26 -0300
committerTorsten Grote <t@grobox.de>2023-02-22 14:29:26 -0300
commit77cd01bf1a23fc218d265a97925624f066c3236b (patch)
treec521353f50d2b42042086cc39692272e6a041024 /wallet/src/main/java/net/taler/wallet/exchanges
parent6e99207a7b525536240f32f04f1bb5457f969025 (diff)
downloadtaler-android-77cd01bf1a23fc218d265a97925624f066c3236b.tar.gz
taler-android-77cd01bf1a23fc218d265a97925624f066c3236b.tar.bz2
taler-android-77cd01bf1a23fc218d265a97925624f066c3236b.zip
[wallet] show fees for peer pull credit
Diffstat (limited to 'wallet/src/main/java/net/taler/wallet/exchanges')
-rw-r--r--wallet/src/main/java/net/taler/wallet/exchanges/ExchangeManager.kt14
1 files changed, 11 insertions, 3 deletions
diff --git a/wallet/src/main/java/net/taler/wallet/exchanges/ExchangeManager.kt b/wallet/src/main/java/net/taler/wallet/exchanges/ExchangeManager.kt
index 5a4c6c2..4a57068 100644
--- a/wallet/src/main/java/net/taler/wallet/exchanges/ExchangeManager.kt
+++ b/wallet/src/main/java/net/taler/wallet/exchanges/ExchangeManager.kt
@@ -17,6 +17,7 @@
package net.taler.wallet.exchanges
import android.util.Log
+import androidx.annotation.WorkerThread
import androidx.lifecycle.LiveData
import androidx.lifecycle.MutableLiveData
import kotlinx.coroutines.CoroutineScope
@@ -81,13 +82,20 @@ class ExchangeManager(
}
fun findExchangeForCurrency(currency: String): Flow<ExchangeItem?> = flow {
- val response = api.request("listExchanges", ExchangeListResponse.serializer())
+ emit(findExchange(currency))
+ }
+
+ @WorkerThread
+ suspend fun findExchange(currency: String): ExchangeItem? {
var exchange: ExchangeItem? = null
- response.onSuccess { exchangeListResponse ->
+ api.request(
+ operation = "listExchanges",
+ serializer = ExchangeListResponse.serializer()
+ ).onSuccess { exchangeListResponse ->
// just pick the first for now
exchange = exchangeListResponse.exchanges.find { it.currency == currency }
}
- emit(exchange)
+ return exchange
}
}