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.

A replying handler over an exactly-once pipeline names it as the mount site’s transform step, right after the policy: b.include(enrich).out_reply(KafkaEosPublish::new("enrich-1")).transform(EosReplies). Every reply then joins the pipeline’s open window paired with its delivery’s consumed offset, making the publishing-handler form exactly-once end to end - the handler just returns the value. The chain takes the codec the same way, with a .codec(..) step.

This works only for subscriptions in Commit::Transactional mode naming that pipeline’s id (they are what stamps the source coordinates being relayed); a reply from any other subscription fails with a clear error. The retry_after deferred-republish fallback does not apply to these replies either: a delayed copy would break the offset-record pairing.

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) -> Self

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() -> Self

Returns the “default value” for a type.

impl<C, Options> PublishTransform<ForReply<C>, Options> for EosReplies

type Destination = Reads

What this transform does to the destination: Reads or Names.

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

Transforms out in place before it is sent, reading the position’s view through cx and resolving the broker’s per-message settings through options.