Skip to content
Snippets Groups Projects
Commit f0aea6e3 authored by Matthias Urhahn's avatar Matthias Urhahn
Browse files

Fix merge regressions.

parent a61a88a6
No related branches found
No related tags found
No related merge requests found
package de.rki.coronawarnapp.util.flow package de.rki.coronawarnapp.util.flow
import io.kotest.assertions.throwables.shouldThrow
import de.rki.coronawarnapp.util.mutate import de.rki.coronawarnapp.util.mutate
import io.kotest.assertions.throwables.shouldThrow
import io.kotest.matchers.shouldBe import io.kotest.matchers.shouldBe
import io.kotest.matchers.types.instanceOf import io.kotest.matchers.types.instanceOf
import io.mockk.coEvery import io.mockk.coEvery
...@@ -85,7 +85,7 @@ class HotDataFlowTest : BaseTest() { ...@@ -85,7 +85,7 @@ class HotDataFlowTest : BaseTest() {
) )
testScope.apply { testScope.apply {
runBlockingTest2(permanentJobs = true) { runBlockingTest2(ignoreActive = true) {
hotData.data.first() shouldBe "Test" hotData.data.first() shouldBe "Test"
hotData.data.first() shouldBe "Test" hotData.data.first() shouldBe "Test"
} }
...@@ -108,7 +108,7 @@ class HotDataFlowTest : BaseTest() { ...@@ -108,7 +108,7 @@ class HotDataFlowTest : BaseTest() {
) )
testScope.apply { testScope.apply {
runBlockingTest2(permanentJobs = true) { runBlockingTest2(ignoreActive = true) {
hotData.data.first() shouldBe "Test" hotData.data.first() shouldBe "Test"
hotData.data.first() shouldBe "Test" hotData.data.first() shouldBe "Test"
} }
...@@ -231,7 +231,7 @@ class HotDataFlowTest : BaseTest() { ...@@ -231,7 +231,7 @@ class HotDataFlowTest : BaseTest() {
sharingBehavior = SharingStarted.Lazily sharingBehavior = SharingStarted.Lazily
) )
testScope.runBlockingTest2(permanentJobs = true) { testScope.runBlockingTest2(ignoreActive = true) {
val sub1 = hotData.data.test(tag = "sub1", startOnScope = this) val sub1 = hotData.data.test(tag = "sub1", startOnScope = this)
val sub2 = hotData.data.test(tag = "sub2", startOnScope = this) val sub2 = hotData.data.test(tag = "sub2", startOnScope = this)
val sub3 = hotData.data.test(tag = "sub3", startOnScope = this) val sub3 = hotData.data.test(tag = "sub3", startOnScope = this)
...@@ -252,7 +252,7 @@ class HotDataFlowTest : BaseTest() { ...@@ -252,7 +252,7 @@ class HotDataFlowTest : BaseTest() {
} }
@Test @Test
fun `update queue is wiped on completion`() = runBlockingTest2(permanentJobs = true) { fun `update queue is wiped on completion`() = runBlockingTest2(ignoreActive = true) {
val valueProvider = mockk<suspend CoroutineScope.() -> Long>() val valueProvider = mockk<suspend CoroutineScope.() -> Long>()
coEvery { valueProvider.invoke(any()) } returns 1 coEvery { valueProvider.invoke(any()) } returns 1
......
...@@ -11,10 +11,10 @@ import kotlin.coroutines.EmptyCoroutineContext ...@@ -11,10 +11,10 @@ import kotlin.coroutines.EmptyCoroutineContext
@ExperimentalCoroutinesApi // Since 1.2.1, tentatively till 1.3.0 @ExperimentalCoroutinesApi // Since 1.2.1, tentatively till 1.3.0
fun TestCoroutineScope.runBlockingTest2( fun TestCoroutineScope.runBlockingTest2(
permanentJobs: Boolean = false, ignoreActive: Boolean = false,
block: suspend TestCoroutineScope.() -> Unit block: suspend TestCoroutineScope.() -> Unit
): Unit = runBlockingTest2( ): Unit = runBlockingTest2(
ignoreActive = permanentJobs, ignoreActive = ignoreActive,
context = coroutineContext, context = coroutineContext,
testBody = block testBody = block
) )
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment