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

queue

val queue: ConcurrentLinkedQueue<T>