pub struct StreamMessage {
pub subject: Subject,
pub sequence: u64,
pub headers: HeaderMap,
pub payload: Bytes,
pub time: OffsetDateTime,
}Expand description
Re-exported type returned by Direct Get operation. A message received directly from the stream, without leveraging a consumer.
Fields§
§subject: Subject§sequence: u64§headers: HeaderMap§payload: Bytes§time: OffsetDateTimeTrait Implementations§
Source§impl Clone for StreamMessage
impl Clone for StreamMessage
Source§fn clone(&self) -> StreamMessage
fn clone(&self) -> StreamMessage
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for StreamMessage
impl Debug for StreamMessage
Source§impl TryFrom<Message> for StreamMessage
impl TryFrom<Message> for StreamMessage
Source§type Error = Error<StreamMessageErrorKind>
type Error = Error<StreamMessageErrorKind>
The type returned in the event of a conversion error.
Source§fn try_from(
message: Message,
) -> Result<StreamMessage, <StreamMessage as TryFrom<Message>>::Error>
fn try_from( message: Message, ) -> Result<StreamMessage, <StreamMessage as TryFrom<Message>>::Error>
Performs the conversion.
Source§impl TryFrom<RawMessage> for StreamMessage
impl TryFrom<RawMessage> for StreamMessage
Source§type Error = Box<dyn Error + Send + Sync>
type Error = Box<dyn Error + Send + Sync>
The type returned in the event of a conversion error.
Source§fn try_from(
value: RawMessage,
) -> Result<StreamMessage, <StreamMessage as TryFrom<RawMessage>>::Error>
fn try_from( value: RawMessage, ) -> Result<StreamMessage, <StreamMessage as TryFrom<RawMessage>>::Error>
Performs the conversion.
Auto Trait Implementations§
impl !Freeze for StreamMessage
impl RefUnwindSafe for StreamMessage
impl Send for StreamMessage
impl Sync for StreamMessage
impl Unpin for StreamMessage
impl UnwindSafe for StreamMessage
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more