Nikky
11/01/2018, 5:35 PMoverride 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)
}
}
}
}