Struct Reply 

pub struct Reply;

The marker of a handler’s reply position: .out(Reply, policy) names the publish policy the value a reply("dest") handler returns leaves through.

A mount site attaches every publish policy with one verb, and this is the marker of the one position that is not an Out slot. It carries no dictionary: what a reply may be is the reply type’s own ReplyShape, while what leaves a slot is the slot marker’s #[publishes(..)] list.

Without the call the reply takes the broker’s own DefaultPublish policy, so naming it is the exception, not the rule.

Examples

use ruststream::memory::prelude::*;

#[subscriber("orders", reply("confirmations"))]
async fn confirm(order: &Order) -> Confirmation {
    Confirmation { id: order.id }
}

fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(MemoryBroker::new(), |b| {
        b.include(confirm).out(Reply, Publish);
    })
}

Trait Implementations

impl Clone for Reply

fn clone(&self) -> Reply

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Reply

impl Debug for Reply

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

Formats the value using the given formatter.

impl Default for Reply

fn default() -> Reply

Returns the “default value” for a type.

impl Eq for Reply

impl Hash for Reply

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Reply

fn eq(&self, other: &Reply) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Reply