MulticastSubject

fun MulticastSubject(expectedCollectors: Int)

Parameters

the element type of the [Flow]
bufferSize

the number of items to buffer until consumers arrive