Type Alias app_frame::queue_consumer::Queue

pub type Queue<T> = Arc<RwLock<PriorityQueue<T, OrderedFloat<f64>>>>;

Aliased Type

struct Queue<T> { /* private fields */ }

Trait Implementations

impl<T: Hash + Eq + Clone> Receiver<T> for Queue<T>

fn receiver( &self, config: QueueReceiveConfig, sleeper: Arc<dyn Sleeper> ) -> QueueReceiver<T>