EricDw

@file:Suppress("KDocUnresolvedReference")

package com.examples.standardfunctions

import androidx.annotation.Nullable
import java.util.*
import java.util.function.Function

// region Person

EricDw

class PipelineBuilder<I, O>(
    actorScope: ActorScope<I>,
    outputChannel: Channel<O>
) : ActorScope<I> by actorScope {
}

EricDw

class PipelineBuilder<I>(
    actorScope: ActorScope<I>
) : ActorScope<I> by actorScope {
}

EricDw

fun <I, O> CoroutineScope.pipeline(init: PipelineBuilder.() -> Unit): Pipeline<I, O> {
}

EricDw

class PipelineBuilder()

EricDw

fun <I, O> CoroutineScope.pipeline(init: suspend PipelineBuilder<I, O>.() -> Unit): Pipeline<I, O> {

EricDw

fun <I, O> CoroutineScope.pipeline(): Pipeline<I, O> {
}

EricDw

private lateinit var intToStringPipeline: Pipeline<Int, String>

@Before
fun setUp() {
    intToStringPipeline = CoroutineTestingScope.pipeline() {
        for (number in channel) {
            send { number.toString() }
        }
    }
}

EricDw

interface Pipeline<I, O> : SendChannel<I>, ReceiveChannel<O>

EricDw

    @Test
    fun given_1_when_send_then_string_of_1() {
        // Arrange
        val input: Int = 1
        val expected: String = "1"
        lateinit var actual: String

        // Act
        CoroutineTestingScope.launch {
            intToStringPipeline.send(input)