MulticastSubject(expectedCollectors: Int)
A subject implementation that awaits a certain number of collectors to start consuming, then allows the producer side to deliver items to them.
bufferSize - the number of items to buffer until consumers arrive
Parameters