Struct ScopedPublisher 

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

A named publisher resolved from a Context, sending through the scope’s publish pipeline.

Returned by Context::publisher. Publishing through it runs the same PublishMiddleware chain (envelope, metrics) as a macro reply, so a manual publish from a handler is not a hole in the pipeline.

Implementations

impl<'a> ScopedPublisher<'a>

pub async fn publish( &self, out: Outgoing<'_>, ) -> Result<(), Box<dyn StdError + Send + Sync>>

Sends out through the publish pipeline to the broker, carrying the originating delivery’s per-delivery extensions for any transactional middleware to read.

Errors

Returns the boxed error from a middleware or the broker publish if either fails.

Trait Implementations

impl Debug for ScopedPublisher<'_>

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

Formats the value using the given formatter.