current

val current: AtomicReference<FlowCollector<T>>