mirror of
https://github.com/bitwarden/android.git
synced 2025-02-23 00:59:16 +03:00
PM-14433 update flow type to nullable so we can handle when an empty table is queried
This commit is contained in:
parent
8f9585e4bc
commit
44eff52ff6
2 changed files with 3 additions and 1 deletions
app/src/main/java/com/x8bit/bitwarden/data/vault/datasource/disk
|
@ -17,6 +17,7 @@ import kotlinx.coroutines.async
|
|||
import kotlinx.coroutines.awaitAll
|
||||
import kotlinx.coroutines.coroutineScope
|
||||
import kotlinx.coroutines.flow.Flow
|
||||
import kotlinx.coroutines.flow.filterNotNull
|
||||
import kotlinx.coroutines.flow.first
|
||||
import kotlinx.coroutines.flow.map
|
||||
import kotlinx.coroutines.flow.merge
|
||||
|
@ -124,6 +125,7 @@ class VaultDiskSourceImpl(
|
|||
override fun getDomains(userId: String): Flow<SyncResponseJson.Domains> =
|
||||
domainsDao
|
||||
.getDomains(userId)
|
||||
.filterNotNull()
|
||||
.map { entity ->
|
||||
withContext(dispatcherManager.default) {
|
||||
json.decodeFromString<SyncResponseJson.Domains>(entity.domainsJson)
|
||||
|
|
|
@ -25,7 +25,7 @@ interface DomainsDao {
|
|||
@Query("SELECT * FROM domains WHERE user_id = :userId")
|
||||
fun getDomains(
|
||||
userId: String,
|
||||
): Flow<DomainsEntity>
|
||||
): Flow<DomainsEntity?>
|
||||
|
||||
/**
|
||||
* Inserts domains into the database.
|
||||
|
|
Loading…
Add table
Reference in a new issue