rei-forks/element-android
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Realm-kotlin : dispatch map to coroutineDispatcher

Browse Source
This commit is contained in:
ganfra 2022-10-20 11:54:12 +02:00
parent e7587a6f47
commit e6f911a64b
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
matrix-sdk-android/src/main/java/org/matrix/android/sdk/internal/database/RealmInstance.kt
View File

@ -20,6 +20,7 @@ import kotlinx.coroutines.async
import kotlinx.coroutines.flow.Flow import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.flatMapConcat import kotlinx.coroutines.flow.flatMapConcat
import kotlinx.coroutines.flow.flow import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.flow.flowOn
import kotlinx.coroutines.flow.map import kotlinx.coroutines.flow.map
import kotlinx.coroutines.launch import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlocking import kotlinx.coroutines.runBlocking
@ -49,7 +50,7 @@ internal fun interface RealmObjectMapper<T : RealmObject, R> {
internal class RealmInstance( internal class RealmInstance(
val coroutineScope: CoroutineScope, val coroutineScope: CoroutineScope,
val realmConfiguration: RealmConfiguration, val realmConfiguration: RealmConfiguration,
coroutineDispatcher: CoroutineDispatcher private val coroutineDispatcher: CoroutineDispatcher
) { ) {
private val realm = private val realm =
@ -72,7 +73,7 @@ internal class RealmInstance(
): Flow<ResultsChange<T>> { ): Flow<ResultsChange<T>> {
return getRealmFlow().flatMapConcat { return getRealmFlow().flatMapConcat {
realmQueryBuilder.build(it).asFlow() realmQueryBuilder.build(it).asFlow()
} }.flowOn(coroutineDispatcher)
} }
fun <T : RealmObject, R> queryList( fun <T : RealmObject, R> queryList(
@ -83,7 +84,7 @@ internal class RealmInstance(
resultChange.list.map { realmObject -> resultChange.list.map { realmObject ->
mapper.map(realmObject) mapper.map(realmObject)
} }
} }.flowOn(coroutineDispatcher)
} }
fun <T : RealmObject> queryFirst( fun <T : RealmObject> queryFirst(
@ -93,7 +94,7 @@ internal class RealmInstance(
realmQueryBuilder.build(it).asFlow() realmQueryBuilder.build(it).asFlow()
}.map { }.map {
Optional.from(it.obj) Optional.from(it.obj)
} }.flowOn(coroutineDispatcher)
} }
fun <T : RealmObject, R> queryPagedList( fun <T : RealmObject, R> queryPagedList(
@ -129,7 +130,7 @@ internal class RealmInstance(
setBoundaryCallback(boundaryCallback) setBoundaryCallback(boundaryCallback)
}.build() }.build()
livePagedList.asFlow() livePagedList.asFlow()
} }.flowOn(coroutineDispatcher)
} }
suspend fun <R> write(block: MutableRealm.() -> R): R { suspend fun <R> write(block: MutableRealm.() -> R): R {