louiscad
07/05/2018, 8:46 AMelizarov
07/05/2018, 6:24 PMfun <T> ReceiveChannel<T>.onEach(block: (T) -> Unit): ReceiveChannel<T> =
produce(onCompletion = consumes()) {
for (it in this@onEach) {
block(it)
send(it)
}
}
louiscad
07/05/2018, 6:27 PMelizarov
07/05/2018, 6:44 PMonEach
.louiscad
07/05/2018, 9:00 PMbroadcast()
function, and having one subscription channel per requirement.