kotlin-flow-extensions / hu.akarnokd.kotlin.flow / MulticastSubject / collectors

collectors

val collectors: AtomicReference<Array<ResumableCollector<T>>>