``` override fun deserialize(response: Response) =...
# kotlin-fuel
n
Copy code
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)
            }
        }
    }
}