Struct StreamMessage 

pub struct StreamMessage<T> {
    pub stream_id: StreamId,
    pub sequence: Sequence,
    pub content: StreamContent<T>,
}

Fields

stream_id: StreamId

Receivers identify streams by (sender, stream_id). This means each node can allocate stream_ids independently and that many streams can be sent on a single network topic.

sequence: Sequence

Identifies the sequence of each message in the stream starting from 0.

content: StreamContent<T>

The content of this stream message

Implementations

impl<T> StreamMessage<T>

pub fn new( stream_id: StreamId, sequence: Sequence, content: StreamContent<T>, ) -> Self

pub fn is_first(&self) -> bool

pub fn is_fin(&self) -> bool

Trait Implementations

impl<T> BorshDeserialize for StreamMessage<T>

where T: BorshDeserialize,

fn deserialize_reader<__R: Read>(reader: &mut __R) -> Result<Self, Error>

fn deserialize(buf: &mut &[u8]) -> Result<Self, Error>

Deserializes this instance from a given slice of bytes. Updates the buffer to point at the remaining bytes.

fn try_from_slice(v: &[u8]) -> Result<Self, Error>

Deserialize this instance from a slice of bytes.

fn try_from_reader<R>(reader: &mut R) -> Result<Self, Error>

where R: Read,

impl<T> BorshSerialize for StreamMessage<T>

where T: BorshSerialize,

fn serialize<__W: Write>(&self, writer: &mut __W) -> Result<(), Error>

impl<T: Clone> Clone for StreamMessage<T>

fn clone(&self) -> StreamMessage<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for StreamMessage<T>

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

Formats the value using the given formatter.

impl<T: PartialEq> PartialEq for StreamMessage<T>

fn eq(&self, other: &StreamMessage<T>) -> 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<T: Eq> Eq for StreamMessage<T>

impl<T> StructuralPartialEq for StreamMessage<T>