Type Definition app_frame::queue_consumer::Queue

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

Trait Implementations

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

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