Enum DispatchState 

pub enum DispatchState {
    NotStarted {
        cmd_tx: Sender<Command>,
        command: Command,
    },
    Reserving(Pin<Box<dyn Future<Output = Result<(), Error>> + Send>>),
    Sent,
}

State of a future before its command has been pushed onto the event-loop channel.

Owns a cloned Command sender rather than borrowing the client, so the operation futures are 'static and can be tokio::spawned or stored.

Variants

NotStarted

First poll has not yet happened; the command is built but not yet sent. Command is an enum, so it is stored inline. No boxing needed.

Fields

cmd_tx: Sender<Command>

command: Command

Reserving(Pin<Box<dyn Future<Output = Result<(), Error>> + Send>>)

Waiting for a permit on the bounded command channel.

Sent

Command has been pushed; nothing left to dispatch.

Implementations

impl DispatchState

pub const fn new(cmd_tx: Sender<Command>, command: Command) -> Self

pub fn poll_dispatch(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Error>>

Drives dispatch until the command has been pushed onto the channel.

Returns Ready(Ok(())) once the command has been sent (or was already sent), Ready(Err(_)) on permanent failure, or Pending while waiting for channel capacity.