Struct RequestQueue 

pub struct RequestQueue { /* private fields */ }

Queue of SysEx requests and writes with at most one in flight.

Implementations

impl RequestQueue

pub fn new(timeout: Duration) -> Self

timeout: how long to wait for a reply before moving on (the official app uses 1 s).

pub fn clear(&mut self)

Drop everything queued and in flight, and any sync in progress.

pub fn start_sync(&mut self, reqs: Vec<Vec<u8>>)

Start a sync: replaces the queue with reqs, whose replies count towards progress.

pub fn read(&mut self, bytes: Vec<u8>)

Queue a read. Ignored when the same request is already waiting.

pub fn write(&mut self, bytes: Vec<u8>)

Queue a write (or any message that must keep its place after queued SysEx). Settings are rewritten whole on every change, so a queued settings write is replaced by the newer one.

pub fn pop(&mut self) -> Option<Request>

The next message to send, if nothing is in flight. Pass it to sent once transmitted.

pub fn sent(&mut self, r: Request, now: Instant)

Record that r went out at now; it is in flight until answered or timed out.

pub fn on_message(&mut self, msg: &Msg) -> Option<Done>

Feed a complete incoming message. Returns the request it answers, if any.

pub fn expire(&mut self, now: Instant) -> Option<Done>

Expire the in-flight request if it has waited longer than the timeout.

pub fn progress(&self) -> (usize, usize)

(done, total) of the current sync; (0, 0) when none is running.

pub fn in_flight(&self) -> Option<&Request>

pub fn len(&self) -> usize

Messages waiting (not counting the one in flight).

pub fn is_empty(&self) -> bool

Trait Implementations

impl Debug for RequestQueue

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

Formats the value using the given formatter.