Vinicius Carvalho
08/24/2018, 12:00 PMDeactivated User
08/24/2018, 12:03 PMVinicius Carvalho
08/24/2018, 12:05 PMVinicius Carvalho
08/24/2018, 12:06 PMwebSocket("/arenas") {
val channel = Channel<Status>()
frameUpdater.subscribe(channel)
for(status in channel){
outgoing.send(Frame.Text("timestamp: $status"))
}
}
Vinicius Carvalho
08/24/2018, 12:06 PMframeUpdater
has a suspended function that keeps producing data to the channelDeactivated User
08/24/2018, 12:08 PMVinicius Carvalho
08/24/2018, 12:08 PMchannel
is no longer opened, and it's not like I'm getting the error on the producer side, it's actually at the for
loopDeactivated User
08/24/2018, 12:08 PMoutgoing.send
methodDeactivated User
08/24/2018, 12:09 PMVinicius Carvalho
08/24/2018, 12:09 PMVinicius Carvalho
08/24/2018, 12:10 PMDeactivated User
08/24/2018, 12:10 PMDeactivated User
08/24/2018, 12:11 PMDeactivated User
08/24/2018, 12:12 PMDeactivated User
08/24/2018, 12:12 PMVinicius Carvalho
08/24/2018, 12:13 PMVinicius Carvalho
08/24/2018, 12:25 PMVinicius Carvalho
08/24/2018, 12:26 PMDeactivated User
08/24/2018, 12:54 PM