Enum StreamRefMessage 

pub enum StreamRefMessage {
    OnSubscribeHandshake,
    CumulativeDemand {
        seq_nr: u64,
    },
    SequencedOnNext {
        seq_nr: u64,
        payload: StreamRefPayloadBytes,
    },
    RemoteStreamCompleted {
        seq_nr: u64,
    },
    RemoteStreamFailure {
        cause: Vec<u8>,
    },
    Ack,
}

Transport-agnostic StreamRefs protocol messages.

Variants

OnSubscribeHandshake

CumulativeDemand

Fields

seq_nr: u64

SequencedOnNext

Fields

seq_nr: u64

payload: StreamRefPayloadBytes

RemoteStreamCompleted

Fields

seq_nr: u64

RemoteStreamFailure

Fields

cause: Vec<u8>

Ack

Implementations

impl StreamRefMessage

pub fn failure_text(&self) -> Option<String>

Trait Implementations

impl Clone for StreamRefMessage

fn clone(&self) -> StreamRefMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamRefMessage

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

Formats the value using the given formatter.

impl Eq for StreamRefMessage

impl PartialEq for StreamRefMessage

fn eq(&self, other: &StreamRefMessage) -> 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 StreamRefMessage