Struct async_nats::jetstream::message::StreamMessage

pub struct StreamMessage {
    pub subject: Subject,
    pub sequence: u64,
    pub headers: HeaderMap,
    pub payload: Bytes,
    pub time: OffsetDateTime,
}

A message received directly from the stream, without leveraging a consumer.

Fields

subject: Subject

sequence: u64

headers: HeaderMap

payload: Bytes

time: OffsetDateTime

Trait Implementations

impl Clone for StreamMessage

fn clone(&self) -> StreamMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StreamMessage

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

Formats the value using the given formatter.

impl TryFrom<Message> for StreamMessage

type Error = Error<StreamMessageErrorKind>

The type returned in the event of a conversion error.

fn try_from(message: Message) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RawMessage> for StreamMessage

type Error = Box<dyn Error + Sync + Send>

The type returned in the event of a conversion error.

fn try_from(value: RawMessage) -> Result<Self, Self::Error>

Performs the conversion.