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

queue

val queue: ConcurrentLinkedQueue<T>