Struct GroupRequest 

pub struct GroupRequest { /* private fields */ }

A consumer’s request for a single past group, handed to a handler via Dynamic::requested_group.

The handler fulfills it by calling Self::accept, which inserts the group into the track cache (resolving every Consumer::fetch_group that joined the attempt) and returns a group::Producer to fill. A relay typically opens a wire FETCH, reads FETCH_OK, then accepts. The request carries its own producer handle, so it works the same whether or not the track has been accepted yet.

Implementations

impl GroupRequest

pub fn sequence(&self) -> u64

The group sequence the consumer wants.

pub fn priority(&self) -> u8

The delivery priority the consumer requested for this group.

pub fn accept(self, info: impl Into<Option<Info>>) -> Result<Producer>

Insert the fetched group into the track cache, resolving the waiting Consumer::fetch_group, and return a group::Producer to fill.

The group’s timescale comes from the track’s Info. info sets that info if the track hasn’t been accepted yet (a fetch with no live subscription), and is ignored once accepted. Returns Error::Duplicate if the group is already present, or the track’s abort error if it closed while pending.

pub fn reject(self, err: Error)

Reject the fetch, resolving every joined Consumer::fetch_group with err.

Trait Implementations

impl Drop for GroupRequest

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.