integration/kotlinx-coroutines-jdk8/test/ChannelsTest.kt

/*
 * Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
 */

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