r4zzz4k
01/15/2018, 8:10 PMfun processor(input: ReceiveChannel<A>): ReceiveChannel<B> = produce {
input.consumeEach {
...
send(...)
}
}
And if not, is there more idiomatic way to do this chaining?dave08
01/15/2018, 8:59 PMdave08
01/15/2018, 9:16 PM