Struct EosReplies 

pub struct EosReplies;

The PublishTransform relaying EOS_SOURCE_HEADER from the originating delivery onto the reply, so the pipeline’s Publisher impl can pair the reply with its consumed offset.

EosPipeline::replies wires it for you; name it directly to keep the explicit TypedPublisher form: TypedPublisher::new(pipeline.clone()).transform(EosReplies). Generic over the handler’s context type, so bare handlers (no ctx parameter, no Ctx extractors) work.

Trait Implementations

impl Clone for EosReplies

fn clone(&self) -> EosReplies

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for EosReplies

impl Debug for EosReplies

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

Formats the value using the given formatter.

impl Default for EosReplies

fn default() -> EosReplies

Returns the “default value” for a type.

impl<C> PublishTransform<C> for EosReplies

fn apply(&self, out: &mut Outgoing<'_>, cx: &PublishContext<'_, C>)

Transforms out in place before it is sent, reading the delivery through cx.