Struct Message

#[non_exhaustive]
pub struct Message { /* private fields */ }

Event Stream message.

Implementations

impl Message

pub fn new(payload: impl Into<Bytes>) -> Message

Creates a new message with the given payload. Headers can be added later.

pub fn new_from_parts( headers: Vec<Header>, payload: impl Into<Bytes>, ) -> Message

Creates a message with the given headers and payload.

pub fn add_header(self, header: Header) -> Message

Adds a header to the message.

pub fn headers(&self) -> &[Header]

Returns all headers.

pub fn payload(&self) -> &Bytes

Returns the payload bytes.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl MessageSizeHint for Message

fn size_hint(&self) -> usize

Returns an estimate of the serialized size of this message in bytes.

impl PartialEq for Message

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Message