EricDw

package com.publicmethod.domain.pipelines

import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
import kotlinx.coroutines.selects.SelectBuilder
import kotlinx.coroutines.selects.select

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

open class PipelineBuilder<I, O>(

EricDw

import org.junit.Assert.assertTrue

fun assertTrueWithMessage(input: Any, expectedOutput: Any, actualOutput: Any) {
    assertTrue(
            createMessage(input, expectedOutput, actualOutput),
            actualOutput == expectedOutput)
}

fun createMessage(input: Any, expectedOutput: Any, actualOutput: Any): String {
    return "input was\n $input\n " +