synhershko
09/03/2019, 7:27 AMbc) 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?