Enum FetchPayload 

pub enum FetchPayload {
    Standalone {
        track_namespace: TrackNamespace,
        track_name: Vec<u8>,
        start_group: VarInt,
        start_object: VarInt,
        end_group: VarInt,
        end_object: VarInt,
    },
    Joining {
        joining_request_id: VarInt,
        joining_start: VarInt,
    },
}

Variants

Standalone

Fields

track_namespace: TrackNamespace

track_name: Vec<u8>

start_group: VarInt

start_object: VarInt

end_group: VarInt

end_object: VarInt

Joining

Fields

joining_request_id: VarInt

The Request ID of the subscription this fetch joins.

Section 8.16 names the field Joining Request ID. Draft-11 spelled the same field Joining Subscribe ID, and the two words are not interchangeable here: a Request ID is drawn from the one space every request shares, so the value identifies a request that happens to be a subscription rather than a subscription in a space of its own.

joining_start: VarInt

The joining start: an offset for a relative fetch, a group for an absolute one.

Trait Implementations

impl Clone for FetchPayload

fn clone(&self) -> FetchPayload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FetchPayload

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

Formats the value using the given formatter.

impl Eq for FetchPayload

impl PartialEq for FetchPayload

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FetchPayload