Struct Streaming 

struct Streaming {
    seats: Vec<Claim>,
    read_aloud: bool,
}

What this connection is streaming: the seats it has claimed takes for - a start’s seat is claimed as soon as its dispatch answers, so a refused one keeps its entry, and a frame that follows a start always finds the seat - and whether it is recording the read-aloud set. A dictation frame carries no seat of its own - and the recording carries none at all - so these are what address one.

Fields

seats: Vec<Claim>

read_aloud: bool

Implementations

impl Streaming

fn any(&self) -> bool

Whether a frame from this connection has anything to land in.

fn claim(&mut self, seat: &SessionSlot)

Claim a seat for a start that is on its way, generation unknown: the dispatch answers before one can be known, and the frame that follows the start must find the seat already here. An existing claim is reset to unknown: the newer take’s DictateStarted has not arrived yet, and an end still in flight for the older one must not retire the claim the newer take is about to stamp.

fn stamp(&mut self, seat: &SessionSlot, generation: u64)

Stamp the claim with the generation its own DictateStarted carried.

fn retire( &mut self, seat: &SessionSlot, outcome: &DictateOutcome, generation: u64, )

Retire the claim an end names, and only that one: a refusal answers a start that never ran, and an older take’s end must not strip the claim a newer take of the same seat registered under.

Trait Implementations

impl Default for Streaming

fn default() -> Self

Returns the “default value” for a type.