Struct Outgoing 

pub struct Outgoing<'a> { /* private fields */ }

A mutable outgoing message flowing through the publish pipeline.

The name is an OutgoingName, which carries a destination from any of the three places one comes from without copying it: the macro reply path borrows a string literal (reply_name(&self) -> &str), a computed name moves in owned, and a name read off the delivery being answered arrives as the delivery’s own buffer. The payload behaves the same way: codec output moves in whole, a rebuilt message carries the buffer it was handed or lends the bytes it was lent, and the first payload_mut or set_payload is what makes the buffer this message’s own. Middleware may change the name, transform the payload, and enrich the headers before the message is sent.

Implementations

impl<'a> Outgoing<'a>

pub fn new( name: impl Into<OutgoingName<'a>>, payload: impl Into<BytesMut>, ) -> Self

Creates an outgoing message with no headers.

Pass a &str (a borrowed destination, the no-allocation case), a String (a computed owned one) or a Str (a buffer something else already holds) for name; pass a BytesMut (codec output moves in) or a &[u8] for the payload.

pub fn name(&self) -> &str

The destination name.

pub fn set_name(&mut self, name: impl Into<OutgoingName<'a>>)

Sets the destination name.

A literal or a borrow costs nothing, a computed String moves in, and a Str read off the delivery shares its buffer rather than copying out of it.

Examples

use ruststream::{Bytes, Str};
use ruststream::runtime::Outgoing;

let mut out = Outgoing::new("answers", b"{}".as_slice());
out.set_name("replies.inbox");
assert_eq!(out.name(), "replies.inbox");

// The same setter takes the buffer a delivery arrived in, with no copy between them.
out.set_name(Str::try_from(Bytes::from_static(b"replies.7"))?);
assert_eq!(out.name(), "replies.7");

pub fn payload(&self) -> &[u8]

The payload bytes.

pub fn payload_mut(&mut self) -> &mut BytesMut

The payload bytes, mutably (for envelope wrapping).

A message that is still lending the bytes it was built from copies them here, once.

pub fn set_payload(&mut self, payload: impl Into<BytesMut>)

Replaces the payload.

pub fn headers(&self) -> &HeaderMap

The outgoing headers.

pub fn headers_mut(&mut self) -> &mut HeaderMap

The outgoing headers, mutably.

Trait Implementations

impl<'a> Clone for Outgoing<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for Outgoing<'a>

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

Formats the value using the given formatter.