multicast

@FlowPreview()
fun <T, R> Flow<T>.multicast(subjectProvider: () -> SubjectAPI<T>, transform: suspend (Flow<T>) -> Flow<R>): Flow<R>
Content copied to clipboard

Shares a single collector towards the upstream source and multicasts values to any number of consumers which then can produce the output flow of values.