blob: d35ee72de0a91468943c7654e4465682640b49fe (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
/*
* Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package kotlinx.coroutines.time
import kotlinx.coroutines.TestBase
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.flow.toList
import kotlinx.coroutines.withVirtualTime
import org.junit.Test
import java.time.Duration
import kotlin.test.assertEquals
class FlowSampleTest : TestBase() {
@Test
public fun testBasic() = withVirtualTime {
expect(1)
val flow = flow {
expect(3)
emit("A")
delay(Duration.ofMillis(1500))
emit("B")
delay(Duration.ofMillis(500))
emit("C")
delay(Duration.ofMillis(250))
emit("D")
delay(Duration.ofMillis(2000))
emit("E")
expect(4)
}
expect(2)
val result = flow.sample(Duration.ofMillis(1000)).toList()
assertEquals(listOf("A", "B", "D"), result)
finish(5)
}
}
|
