@Test
    fun outputstreamTest() {
        val myPool = newFixedThreadPoolContext(16, "MyPool")
        val inStream: MutableList<ByteOutputStream> = mutableListOf()
        for (i in 0..5) {
            inStream.add(ByteOutputStream())
            launch(myPool) {
                while (true) {
                    inStream[i].write("${Thread.currentThread()}".toByteArray())
                    Thread.sleep(1000)
                }
            }
        }

        inStream.forEach { stream ->
            launch {
                stream.newInputStream().bufferedReader().useLines {
                    it.forEach {
                        println(it)
                    }
                }
            }
        }
        Thread.sleep(99999999)
    }