From e85b33b233b71f4c346a87e698603af1ad42b79d Mon Sep 17 00:00:00 2001 From: Alec Strong Date: Thu, 8 Sep 2022 08:43:57 -0400 Subject: [PATCH] Update FlowExtensions.kt --- .../kotlin/app/cash/sqldelight/coroutines/FlowExtensions.kt | 1 - .../kotlin/app/cash/sqldelight/coroutines/QueryAsFlowTest.kt | 3 ++- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/extensions/coroutines-extensions/src/commonMain/kotlin/app/cash/sqldelight/coroutines/FlowExtensions.kt b/extensions/coroutines-extensions/src/commonMain/kotlin/app/cash/sqldelight/coroutines/FlowExtensions.kt index 341719c2cf9..f1c3a0f8986 100644 --- a/extensions/coroutines-extensions/src/commonMain/kotlin/app/cash/sqldelight/coroutines/FlowExtensions.kt +++ b/extensions/coroutines-extensions/src/commonMain/kotlin/app/cash/sqldelight/coroutines/FlowExtensions.kt @@ -22,7 +22,6 @@ import app.cash.sqldelight.Query import app.cash.sqldelight.async.coroutines.awaitAsList import app.cash.sqldelight.async.coroutines.awaitAsOne import app.cash.sqldelight.async.coroutines.awaitAsOneOrNull -import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.channels.Channel import kotlinx.coroutines.channels.Channel.Factory.CONFLATED import kotlinx.coroutines.flow.Flow diff --git a/extensions/coroutines-extensions/src/commonTest/kotlin/app/cash/sqldelight/coroutines/QueryAsFlowTest.kt b/extensions/coroutines-extensions/src/commonTest/kotlin/app/cash/sqldelight/coroutines/QueryAsFlowTest.kt index 9ad165d34a9..baa9acd26eb 100644 --- a/extensions/coroutines-extensions/src/commonTest/kotlin/app/cash/sqldelight/coroutines/QueryAsFlowTest.kt +++ b/extensions/coroutines-extensions/src/commonTest/kotlin/app/cash/sqldelight/coroutines/QueryAsFlowTest.kt @@ -6,6 +6,7 @@ import app.cash.sqldelight.coroutines.Employee.Companion.USERNAME import app.cash.sqldelight.coroutines.TestDb.Companion.TABLE_EMPLOYEE import app.cash.turbine.test import kotlinx.coroutines.CoroutineStart.UNDISPATCHED +import kotlinx.coroutines.Dispatchers import kotlinx.coroutines.launch import kotlinx.coroutines.yield import kotlin.test.Test @@ -103,7 +104,7 @@ class QueryAsFlowTest : DbTest { @Test fun queryCanBeCollectedMoreThanOnce() = runTest { db -> val flow = db.createQuery(TABLE_EMPLOYEE, "$SELECT_EMPLOYEES WHERE $USERNAME = 'john'", MAPPER) .asFlow() - .mapToOneNotNull() + .mapToOneNotNull(Dispatchers.Default) val employee = Employee("john", "John Johnson")