integration/kotlinx-coroutines-jdk8/src/test/kotlin/kotlinx/coroutines/experimental/channels8/ChannelsTest.kt

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()))
    }
}