override fun deserialize(response: Response): Unit {
  response.body().toStream().bufferedReader().forEachLine { line ->
                launch {
                    val msg = ApiMessage.decode(line)
                    if (msg.event != "api_connect") {
                        send(msg)
                    }
                }
            }
}

.dataStream

override fun deserialize(response: Response) = launch(<http://Dispatchers.IO|Dispatchers.IO> + CoroutineName("msgReceiver")) {
    <http://logger.info|logger.info>("connection open")
    response.dataStream.bufferedReader().useLines { lines ->
        lines.forEach { line ->
            val msg = ApiMessage.decode(line)
            if (msg.event != "api_connect") {
                send(msg)
            }
        }
    }
}

compile(group: "com.github.kittinunf.Fuel", name: "fuel-coroutines", version: "-SNAPSHOT")

[00:00:28] [DefaultDispatcher-worker-2/ERROR] [matterlink]: java.lang.UnsupportedOperationException: Decoding chunked is not supported. [gzip, deflate; q=0.5] are.