Struct TrackProducer 

pub struct TrackProducer {
    pub info: Track,
    /* private fields */
}

A producer for a track, used to create new groups.

Fields

info: Track

Implementations

impl TrackProducer

pub fn new(info: Track) -> Self

pub fn create_group(&mut self, info: Group) -> Result<GroupProducer>

Create a new group with the given sequence number.

pub fn append_group(&mut self) -> Result<GroupProducer>

Create a new group with the next sequence number.

pub fn write_frame<B: Into<Bytes>>(&mut self, frame: B) -> Result<()>

Create a group with a single frame.

pub fn finish(&mut self) -> Result<()>

Mark the track as finished after the last appended group.

Sets the final sequence to one past the current max_sequence. No new groups at or above this sequence can be appended. NOTE: Old groups with lower sequence numbers can still arrive.

pub fn close(&mut self) -> Result<()>

👎Deprecated: use finish() or finish_at(sequence) instead

Mark the track as finished after the last appended group.

Deprecated: use Self::finish for this behavior, or Self::finish_at to set an explicit final sequence.

pub fn finish_at(&mut self, sequence: u64) -> Result<()>

Mark the track as finished at an exact final sequence.

The caller must pass the current max_sequence exactly. Freezes the final boundary at one past the current max_sequence. No new groups at or above that sequence can be created. NOTE: Old groups with lower sequence numbers can still arrive.

pub fn abort(&mut self, err: Error) -> Result<()>

Abort the track with the given error.

pub fn consume(&self) -> TrackConsumer

Create a new consumer for the track, starting at the latest group.

pub async fn unused(&self) -> Result<()>

Block until there are no active consumers.

pub fn is_closed(&self) -> bool

Return true if the track has been closed.

pub fn is_clone(&self, other: &Self) -> bool

Return true if this is the same track.

Trait Implementations

impl Clone for TrackProducer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl From<Track> for TrackProducer

fn from(info: Track) -> Self

Converts to this type from the input type.