Struct PublishNext 

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

A cursor over the rest of the publish pipeline, ending in the broker send. Handed to a PublishLayer; call run to continue.

Implementations

impl<'a, N: PublishPipeline> PublishNext<'a, N>

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

Runs the rest of the pipeline (the remaining middleware, then the send).

Trait Implementations

impl<N> Debug for PublishNext<'_, N>

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

Formats the value using the given formatter.