Struct ReplyAddress 

#[non_exhaustive]
pub struct ReplyAddress {
    pub location: String,
}

Where a client finds the address a reply is published to: the AsyncAPI operation reply address object.

Filled from the publish policy’s reply_address_location, which a broker answers with the header carrying the address ($message.header#/reply-to).

Examples

use ruststream::asyncapi::Spec;

/// Where a client generator finds the address to read an operation's reply from.
fn reply_location<'a>(spec: &'a Spec, operation: &str) -> Option<&'a str> {
    let reply = spec.operations.get(operation)?.reply.as_ref()?;
    reply
        .address
        .as_ref()
        .map(|address| address.location.as_str())
}

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

location: String

The runtime expression naming the address, per the specification’s grammar.

Implementations

impl ReplyAddress

pub fn new(location: impl Into<String>) -> Self

The address a reply is published to, as a runtime expression.

Examples

use ruststream::asyncapi::{ReplyAddress, Spec};

/// The gateway in front of the service answers on the inbox a request names, which the
/// broker underneath cannot say, so the published document is completed here.
fn add_gateway_reply(spec: &mut Spec) {
    if let Some(reply) = spec
        .operations
        .get_mut("receive_requests")
        .and_then(|operation| operation.reply.as_mut())
    {
        reply.address = Some(ReplyAddress::new("$message.header#/reply-to"));
    }
}

Trait Implementations

impl Clone for ReplyAddress

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 ReplyAddress

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

Formats the value using the given formatter.

impl Serialize for ReplyAddress

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.