Running each subscriber in its own coroutine with ...
# coroutines
e
Running each subscriber in its own coroutine with
consumeEach
should be producing similar result. I wonder what could go wrong....