blob: cfcbb5218ba14f4debab1585908a1ce76b541327 [file] [log] [blame]
/*
* Copyright 2016-2019 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package kotlinx.coroutines.flow
import kotlinx.coroutines.*
import kotlin.test.*
class ToCollectionTest : TestBase() {
private val flow = flow {
repeat(10) {
emit(42)
}
}
private val emptyFlow = flowOf<Int>()
@Test
fun testToList() = runTest {
assertEquals(List(10) { 42 }, flow.toList())
assertEquals(emptyList(), emptyFlow.toList())
}
@Test
fun testToSet() = runTest {
assertEquals(setOf(42), flow.toSet())
assertEquals(emptySet(), emptyFlow.toSet())
}
}