kotlin-flow-extensions / hu.akarnokd.kotlin.flow / UnicastWorkSubject / current

current

val current: AtomicReference<FlowCollector<T>>