pub struct StreamRefPayloadBatch { /* private fields */ }Expand description
A contiguous batch of already-encoded SequencedOnNext payloads.
Implementations§
Source§impl StreamRefPayloadBatch
impl StreamRefPayloadBatch
pub fn new(stream_ref_id: StreamRefId, first_seq_nr: u64) -> Self
pub fn stream_ref_id(&self) -> StreamRefId
pub fn first_seq_nr(&self) -> u64
pub fn count(&self) -> usize
pub fn is_empty(&self) -> bool
pub fn payload_len(&self, index: usize) -> usize
pub fn payload(&self, index: usize) -> &[u8] ⓘ
pub fn push_payload<T>(&mut self, item: T) -> StreamResult<()>where
T: StreamRefPayload,
Trait Implementations§
Source§impl Clone for StreamRefPayloadBatch
impl Clone for StreamRefPayloadBatch
Source§fn clone(&self) -> StreamRefPayloadBatch
fn clone(&self) -> StreamRefPayloadBatch
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl Freeze for StreamRefPayloadBatch
impl RefUnwindSafe for StreamRefPayloadBatch
impl Send for StreamRefPayloadBatch
impl Sync for StreamRefPayloadBatch
impl Unpin for StreamRefPayloadBatch
impl UnsafeUnpin for StreamRefPayloadBatch
impl UnwindSafe for StreamRefPayloadBatch
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage