Struct PublishDynStack 

pub struct PublishDynStack(/* private fields */);

A single static PublishLayer wrapping a runtime-built, frozen list of PublishDynLayer.

The publish-side counterpart of the consume-side DynStack: the opt-in escape hatch for a middleware set decided at runtime (from config, a loop, feature flags) that therefore cannot be a compile-time publish_layer chain. Add it like any other middleware; only the middleware inside it pay one boxed future per layer.

use std::sync::Arc;
use ruststream::runtime::{PublishDynLayer, PublishDynStack};

fn stack(
    middleware: Vec<Arc<dyn PublishDynLayer>>,
) -> PublishDynStack {
    PublishDynStack::new(middleware)
}

Implementations

impl PublishDynStack

pub fn new( middleware: impl IntoIterator<Item = Arc<dyn PublishDynLayer>>, ) -> Self

Builds a stack from a list of middleware, applied in iteration order (first runs outermost).

Trait Implementations

impl Clone for PublishDynStack

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PublishDynStack

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

Formats the value using the given formatter.

impl PublishLayer for PublishDynStack

fn on_publish<'a, N: PublishPipeline, P: Publisher>( &'a self, out: &'a mut Outgoing<'a>, next: PublishNext<'a, N, P>, ) -> impl Future<Output = Result<(), Box<dyn StdError + Send + Sync>>> + Send + 'a

Handle the outgoing message, calling next to continue the pipeline.