A Unit Test demostrating how I expected the Pipeline Interface to look.

PipelineDSLTest.kt

    @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)
            actual = intToStringPipeline.receive()
        }

        // Assert
        Assert.assertEquals(expected, actual)
    }