Derk-Jan Karrenbeld
11/01/2018, 4:59 PMoverride fun deserialize(response: Response): Unit {
response.body().toStream().bufferedReader().forEachLine { line ->
launch {
val msg = ApiMessage.decode(line)
if (msg.event != "api_connect") {
send(msg)
}
}
}
}