A small piece of code reproducing ByteReadChannel bugs

[kobe2000]

Hi
I reported an issue to ktor framework, which is in fact an known bug in kotlinx.coroutines, so I paste the code here too.

import io.ktor.network.sockets.aSocket
import io.ktor.network.sockets.openReadChannel
import io.ktor.network.sockets.openWriteChannel
import kotlinx.coroutines.experimental.async
import kotlinx.coroutines.experimental.launch
import kotlinx.coroutines.experimental.runBlocking
import java.net.InetSocketAddress

fun main(args: Array<String>) {

    async {
        val server = aSocket().tcp().bind(InetSocketAddress(12000))
        while (true) {
            println("accept")
            val socket = server.accept()
            launch {
                val wc = socket.openWriteChannel(autoFlush = true)
                while (true) {
                    wc.writeByte(1)
                    wc.writeInt(1)
                }
            }
        }
    }

    Thread.sleep(1000)

    runBlocking {
        aSocket().tcp().connect(InetSocketAddress("localhost", 12000)).use { socket ->
            val rc = socket.openReadChannel()
            while (true) {
                check(rc.readByte() == 1.toByte()) { "byte" }
                check(rc.readInt() == 1) { "int" }
            }
        }
    }
}