Struct PublishStateMachine 

pub struct PublishStateMachine {
    state: PublishState,
}

Pure state machine for a MoQT publish request (publisher side). Transitions: Idle → Publishing → Active → Done.

Fields

state: PublishState

Implementations

impl PublishStateMachine

pub fn on_publish_received(&mut self) -> Result<(), PublishFlowError>

Idle -> Publishing (PUBLISH received from the peer).

pub fn on_publish_ok_sent(&mut self) -> Result<(), PublishFlowError>

Publishing -> Active (PUBLISH_OK sent to the offering peer).

pub fn on_publish_error_sent(&mut self) -> Result<(), PublishFlowError>

Publishing -> Done (PUBLISH_ERROR sent to the offering peer).

pub fn on_publish_done_received(&mut self) -> Result<(), PublishFlowError>

Active -> Done (PUBLISH_DONE received from the offering peer).

pub fn on_unsubscribe_sent(&mut self) -> Result<(), PublishFlowError>

Active -> Done (UNSUBSCRIBE sent to the offering peer).

The same transition as the one above and a separate name, because a refusal has to say which of the two events was refused.

pub fn on_unsubscribe_received(&mut self) -> Result<(), PublishFlowError>

Active -> Done (UNSUBSCRIBE received from the subscribing peer).

The mirror of the one above, on an offer this endpoint made rather than one it took. Both directions are held in this one map, so the event name is the only thing that says which of them was refused.

impl PublishStateMachine

pub fn new() -> Self

Creates a new state machine in the PublishState::Idle state.

pub fn state(&self) -> PublishState

Returns the current state of the publish request.

pub fn on_publish_sent(&mut self) -> Result<(), PublishError>

Idle → Publishing (PUBLISH sent).

pub fn on_publish_ok(&mut self) -> Result<(), PublishError>

Publishing → Active (PUBLISH_OK received).

pub fn on_publish_error(&mut self) -> Result<(), PublishError>

Publishing → Done (PUBLISH_ERROR received).

pub fn on_publish_done_sent(&mut self) -> Result<(), PublishError>

Active → Done (PUBLISH_DONE sent by publisher).

Trait Implementations

impl Default for PublishStateMachine

fn default() -> Self

Returns the “default value” for a type.