I tried to implement

rx.Observable.switchMap

for Channels: https://gist.github.com/hannesstruss/927ec8120d7cb312d80685f230d50c6e It's kind of working ("just" deadlocking occasionally), but I found the way there to be very brittle, so much depends on using the right coroutine contexts in the right places. E.g. when not using

Unconfined

for

produce

in the

transform

function, the wrong channel will be selected in

whileSelect

and the outcome will be wrong. Any general hints on how to approach problems like that?

Hi,

switchMap

is non-trivial one. You should also cancel

current

when receiving new event from

input

and propagate cancellation to downstream from

input

.