Struct OpQueue 

pub(crate) struct OpQueue<Args = (), Output = ()> {
    op_requested: Option<(String, Args)>,
    op_in_progress: bool,
    last_op_result: Option<Output>,
}

A single-item queue that allows callers to request an operation to be performed later.

let queue = OpQueue::default();

// Request work to be done.
queue.request_op("user pushed a button", ());

// In a later iteration of the server loop, we start the work.
if let Some((_cause, ())) = queue.should_start_op() {
    dbg!("Some slow operation here");
}

// In an even later iteration of the server loop, we can see that the work
// was completed.
if !queue.op_in_progress() {
    dbg!("Work has been done!");
}

Fields

op_requested: Option<(String, Args)>

op_in_progress: bool

last_op_result: Option<Output>

Implementations

impl<Args: Debug, Output> OpQueue<Args, Output>

pub(crate) fn request_op(&mut self, reason: String, args: Args)

Request an operation to start.

pub(crate) fn should_start_op(&mut self) -> Option<(String, Args)>

If there was an operation requested, mark this queue as started and return the request arguments.

pub(crate) fn op_completed(&mut self, result: Output)

Mark an operation as completed.

pub(crate) fn last_op_result(&self) -> Option<&Output>

Get the result of the last operation.

pub(crate) fn op_in_progress(&self) -> bool

pub(crate) fn op_requested(&self) -> bool

Trait Implementations

impl<Args: Debug, Output: Debug> Debug for OpQueue<Args, Output>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Args, Output> Default for OpQueue<Args, Output>

fn default() -> Self

Returns the “default value” for a type.