| package kotlinx.coroutines.experimental.channels8 |
| |
| import kotlinx.coroutines.experimental.TestBase |
| import kotlinx.coroutines.experimental.channels.asReceiveChannel |
| import kotlinx.coroutines.experimental.channels.toList |
| import kotlinx.coroutines.experimental.runBlocking |
| import org.junit.Assert.assertEquals |
| import org.junit.Test |
| import java.util.stream.Collectors |
| |
| class ChannelsTest : TestBase() { |
| private val testList = listOf(1, 2, 3) |
| |
| @Test |
| fun testCollect() = runBlocking { |
| assertEquals(testList, testList.asReceiveChannel().collect(Collectors.toList())) |
| } |
| |
| @Test |
| fun testStreamAsReceiveChannel() = runBlocking { |
| assertEquals(testList, testList.stream().asReceiveChannel().toList()) |
| } |
| |
| @Test |
| fun testReceiveChannelAsStream() { |
| assertEquals(testList, testList.asReceiveChannel().asStream().collect(Collectors.toList())) |
| } |
| } |