I have a BroadcastChannel (`bc`) with multiple con...
# coroutines
s
I have a BroadcastChannel (
bc
) with multiple consumers, each process the messages from
bc
and sends messsages to another “sink” channel
t
. The “sink” channel is defined as
val t = Channel<Tag>(Channel.UNLIMITED)
and I can consistently reproduce a situation where messages are sent to it but the consumer of
t
never sees them. If I change t’s definition to
val t = Channel<Tag>()
- meaning changing from UNLIMITED to RENDEZVOUS - all works as expected (no messages are dropped). Any idea what’s going on?