aboutsummaryrefslogtreecommitdiffstats
path: root/reactive/kotlinx-coroutines-reactor/test/ReactorContextTest.kt
diff options
context:
space:
mode:
authorAndroid Build Coastguard Worker <android-build-coastguard-worker@google.com>2021-08-23 23:55:41 +0000
committerAndroid Build Coastguard Worker <android-build-coastguard-worker@google.com>2021-08-23 23:55:41 +0000
commitffe1b7dc19f3fbe1bc4a5f4f1e28c64cd68c5371 (patch)
tree747e5be83c6e6a2e2d9a164ebd03c5e45e6ec952 /reactive/kotlinx-coroutines-reactor/test/ReactorContextTest.kt
parent2bbecd60d31b5d0b48847f67e741018f5ae7aa07 (diff)
parent531d55eaeac09ad6cde55687ef802d4235040985 (diff)
downloadplatform_external_kotlinx.coroutines-ffe1b7dc19f3fbe1bc4a5f4f1e28c64cd68c5371.tar.gz
platform_external_kotlinx.coroutines-ffe1b7dc19f3fbe1bc4a5f4f1e28c64cd68c5371.tar.bz2
platform_external_kotlinx.coroutines-ffe1b7dc19f3fbe1bc4a5f4f1e28c64cd68c5371.zip
Snap for 7668063 from 531d55eaeac09ad6cde55687ef802d4235040985 to simpleperf-releasesimpleperf-release
Change-Id: I844c9c61f2e31a265c36a483e1509e0e08c508d6
Diffstat (limited to 'reactive/kotlinx-coroutines-reactor/test/ReactorContextTest.kt')
-rw-r--r--reactive/kotlinx-coroutines-reactor/test/ReactorContextTest.kt12
1 files changed, 4 insertions, 8 deletions
diff --git a/reactive/kotlinx-coroutines-reactor/test/ReactorContextTest.kt b/reactive/kotlinx-coroutines-reactor/test/ReactorContextTest.kt
index aff29241..577238be 100644
--- a/reactive/kotlinx-coroutines-reactor/test/ReactorContextTest.kt
+++ b/reactive/kotlinx-coroutines-reactor/test/ReactorContextTest.kt
@@ -20,7 +20,7 @@ class ReactorContextTest : TestBase() {
}
} .contextWrite(Context.of(2, "2", 3, "3", 4, "4", 5, "5"))
.contextWrite { ctx -> ctx.put(6, "6") }
- assertEquals(mono.awaitFirst(), "1234567")
+ assertEquals(mono.awaitSingle(), "1234567")
}
@Test
@@ -43,22 +43,18 @@ class ReactorContextTest : TestBase() {
(1..3).forEach { append(ctx.getOrDefault(it, "noValue")) }
}
} .contextWrite(Context.of(2, "2"))
- .awaitFirst()
+ .awaitSingle()
assertEquals(result, "123")
}
@Test
fun testMonoAwaitContextPropagation() = runBlocking(Context.of(7, "7").asCoroutineContext()) {
- assertEquals(createMono().awaitFirst(), "7")
- assertEquals(createMono().awaitFirstOrDefault("noValue"), "7")
- assertEquals(createMono().awaitFirstOrNull(), "7")
- assertEquals(createMono().awaitFirstOrElse { "noValue" }, "7")
- assertEquals(createMono().awaitLast(), "7")
assertEquals(createMono().awaitSingle(), "7")
+ assertEquals(createMono().awaitSingleOrNull(), "7")
}
@Test
- fun testFluxAwaitContextPropagation() = runBlocking<Unit>(
+ fun testFluxAwaitContextPropagation() = runBlocking(
Context.of(1, "1", 2, "2", 3, "3").asCoroutineContext()
) {
assertEquals(createFlux().awaitFirst(), "1")