GiftedHacker/tangem-app-android-audited
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Updated on 2026-08-14

Browse source
This commit is contained in:
Tangem 2025-11-24 12:21:14 +04:00
parent e381fafeb8
commit 7cb4b57fe9
21 changed files with 556 additions and 230 deletions
Download patch file Download diff file Expand all files Collapse all files

13
domain/core/src/main/kotlin/com/tangem/domain/core/flow/FlowSupplier.kt
View file

@ -2,6 +2,7 @@ package com.tangem.domain.core.flow
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.firstOrNull
import kotlinx.coroutines.withTimeoutOrNull
/**
* [Flow] supplier
@ -16,8 +17,14 @@ interface FlowSupplier<Params : Any, Data : Any> {
/** Supply [Flow] by [params] */
operator fun invoke(params: Params): Flow<Data>
/** Get first [Data] by [params] or null if [Flow] is empty */
suspend fun getSyncOrNull(params: Params): Data? {
return invoke(params).firstOrNull()
/** Synchronously get first value or null from [Flow] within [timeMillis] */
suspend fun getSyncOrNull(params: Params, timeMillis: Long? = null): Data? {
val block = suspend { invoke(params).firstOrNull() }
return if (timeMillis == null) {
block()
} else {
withTimeoutOrNull(timeMillis) { block() }
}
}
}