Struct ObjectHeader 

pub struct ObjectHeader {
    pub object_id: VarInt,
    pub payload_length: VarInt,
    pub object_status: ObjectStatus,
}

Object within a subgroup stream.

Encoding: object_id(vi), payload_length(vi), if payload_length == 0: object_status(vi) else: payload bytes (status is implicitly Normal)

Fields

object_id: VarInt

Object identifier within the subgroup.

payload_length: VarInt

Length of the object payload in bytes.

object_status: ObjectStatus

Status of this object.

Implementations

impl ObjectHeader

pub fn encode(&self, buf: &mut impl BufMut)

Encode the object header into the buffer.

pub fn encode_checked(&self, buf: &mut impl BufMut) -> Result<(), CodecError>

Encode the header, refusing a status the framing cannot carry.

Section 7.3.1 puts the Object Status field on the wire only when the Object Payload Length is zero, and Section 7.1.1.1 says “Any object with a status code other than zero MUST have an empty payload”. A non-zero status paired with a non-zero payload length therefore has no encoding at all: Self::encode drops the status and the peer reads an ordinary object, which is a different object from the one the caller described. This refuses instead.

The datagram types on this draft already refuse the same pairing. These two did not, and they are the ones a publisher writes on every stream.

Errors

CodecError::InvalidField if a non-zero Object Status is paired with a non-zero Object Payload Length.

pub fn decode(buf: &mut impl Buf) -> Result<Self, CodecError>

Decode an object header from the buffer.

Trait Implementations

impl Clone for ObjectHeader

fn clone(&self) -> ObjectHeader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObjectHeader

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

Formats the value using the given formatter.

impl Eq for ObjectHeader

impl PartialEq for ObjectHeader

fn eq(&self, other: &ObjectHeader) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ObjectHeader