diff options
author | Torsten Grote <t@grobox.de> | 2023-02-22 14:29:26 -0300 |
---|---|---|
committer | Torsten Grote <t@grobox.de> | 2023-02-22 14:29:26 -0300 |
commit | 77cd01bf1a23fc218d265a97925624f066c3236b (patch) | |
tree | c521353f50d2b42042086cc39692272e6a041024 /wallet/src/main/java/net/taler/wallet/exchanges | |
parent | 6e99207a7b525536240f32f04f1bb5457f969025 (diff) | |
download | taler-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.kt | 14 |
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 } } |