Struct PublishNext 

pub struct PublishNext<'a> { /* private fields */ }

A cursor over the remaining publish middleware, ending in the broker publisher.

Carries the originating delivery’s per-delivery Extensions (via extensions), so a transactional middleware or publisher can read a broker-supplied commit token at commit time. A publish with no originating delivery (a fresh startup publish) sees an empty map.

Implementations

impl<'a> PublishNext<'a>

pub fn run( self, out: &'a mut Outgoing<'a>, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn StdError + Send + Sync>>> + Send + 'a>>

Runs the next middleware, or sends the message if the pipeline is exhausted.

pub fn extensions(&self) -> &Extensions

The originating delivery’s per-delivery Extensions, for a transactional middleware to read a broker-supplied commit token. Empty for a publish with no originating delivery.

Trait Implementations

impl Debug for PublishNext<'_>

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

Formats the value using the given formatter.