Struct ResponseQueue

pub(super) struct ResponseQueue<T> {
    queue: Mutex<VecDeque<T>>,
    condvar: CondVar,
}

A queue for handling responses

Fields

queue: Mutex<VecDeque<T>>

condvar: CondVar

Implementations

impl<T: Debug> ResponseQueue<T>

pub(super) fn new() -> Arc<Self>

pub(super) async fn recv(&self) -> T

Wait while the queue is empty, remove and return the item from the queue, panicking if empty (shouldn’t happen)

pub(super) async fn push(&self, res: T)

Push an item into the queue, notify all waiting tasks that the condvar has changed