dave08
10/02/2017, 8:05 AMdave08
10/02/2017, 8:40 AMclass ProducerHandler<T>(val context: Context): Handler<T> {
override fun handle(event: T) {
launch(context.dispatcher()) {
_channel.send(event)
}
}
private val _channel = Channel<T>()
val channel: ReceiveChannel<T> = _channel
}