Struct ForReply 

pub struct ForReply<C = ()>(/* private fields */);

The kind of a reply position: the transform reads the delivery it answers, as a PublishContext over the handler’s own context type C.

Trait Implementations

impl<C> Clone for ForReply<C>

where C: Clone,

fn clone(&self) -> ForReply<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C> ContextKind for ForReply<C>

type View<'a> = PublishContext<'a, C> where ForReply<C>: 'a

The view a transform of this kind reads, borrowed for the length of one publish.

impl<C> Copy for ForReply<C>

where C: Copy,

impl<C> Debug for ForReply<C>

where C: Debug,

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

Formats the value using the given formatter.

impl<C> Default for ForReply<C>

where C: Default,

fn default() -> ForReply<C>

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.

impl<Options> PublishTransform<ForReply<KafkaContext>, Options> for ToSourceTopic

type Destination = Names

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

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

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.