Struct Publisher 

pub struct Publisher { /* private fields */ }

One sans-I/O publication lifecycle.

Implementations

impl Publisher

pub fn start( config: Config, start: Start, ) -> Result<(Self, Vec<Output>), StartError>

Start one initial publication.

pub fn is_active(&self) -> bool

Whether this lifecycle still owns state.

pub fn entity_tag(&self) -> Option<&str>

Current entity tag after a successful operation.

pub fn granted_expiry(&self) -> Option<Duration>

Current granted expiry after a successful operation.

pub fn response( &mut self, response: Option<&Response>, cnonce: &str, ) -> Vec<Output>

Consume a final response; cnonce is fresh driver entropy for a possible digest retry.

pub fn modify( &mut self, body: Bytes, content_type: String, ) -> Result<Vec<Output>, CommandError>

Replace event state conditionally.

pub fn remove(&mut self) -> Result<Vec<Output>, CommandError>

Remove event state. At most one request is queued behind a live operation.

pub fn timer_fired(&mut self, timer: Timer, generation: u64) -> Vec<Output>

Fire one exact timer generation.

pub fn shutdown_deadline(&mut self) -> Vec<Output>

Force the bounded runtime shutdown deadline.

Trait Implementations

impl Debug for Publisher

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

Formats the value using the given formatter.