Struct PublishStack 

pub struct PublishStack<Head, Tail> { /* private fields */ }

Prepends a PublishLayer Head to a PublishPipeline Tail. Built by RustStream::publish_layer; you rarely name it directly.

Trait Implementations

impl<Head: Clone, Tail: Clone> Clone for PublishStack<Head, Tail>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Head: Copy, Tail: Copy> Copy for PublishStack<Head, Tail>

impl<Head: Debug, Tail: Debug> Debug for PublishStack<Head, Tail>

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

Formats the value using the given formatter.

impl<Head: Default, Tail: Default> Default for PublishStack<Head, Tail>

fn default() -> Self

Returns the “default value” for a type.

impl<W, Head: PublishLayer, Tail: PublishPipeline> OutPipeline<W> for PublishStack<Head, Tail>

type Error<E: StdError + Send + Sync + 'static> = PipelinePublishError

The error a publish through this path reports, over the leaf publisher’s own error E: the leaf’s error itself when nothing runs, a PipelinePublishError once the app’s middleware does.

fn from_publish_error<E: StdError + Send + Sync + 'static>( err: E, ) -> PipelinePublishError

Reports a leaf-publisher error that did not travel this path (a transaction call, a request round trip) in the entry’s error type.

async fn send<P>( &self, leaf: &P, msg: OutgoingFor<'_, W::Payload>, options: Option<&P::Options>, ) -> Result<(), PipelinePublishError>

where W: Publisher, P: Publisher<Options = W::Options, Payload = W::Payload>,

Sends one message through the path into leaf, the slot’s attributed publisher, with the broker’s per-message settings the call site adjusted.

impl<Head: PublishLayer, Tail: PublishPipeline> PublishPipeline for PublishStack<Head, Tail>

fn run<'a, P: Publisher>( &'a self, out: &'a mut Outgoing<'a>, send: &'a P, options: Option<&'a P::Options>, ) -> impl Future<Output = Result<(), Box<dyn StdError + Send + Sync>>> + Send + 'a

Runs out through the remaining middleware, then sends it via send with the broker’s per-message settings the call site adjusted (None on a reply, which has no call site).