Struct SegmentClock 

pub struct SegmentClock { /* private fields */ }

Available on crate features hls or record only.

Tracks segment boundaries from a frame stream’s keyframes and timestamps.

use arcly_stream::segment::SegmentClock;
use arcly_stream::{CodecId, MediaFrame};
use bytes::Bytes;

let key = |pts| MediaFrame::new_video(pts, pts, Bytes::new(), CodecId::H264, true);
let mut clock = SegmentClock::new(2); // 2-second target

// First keyframe opens segment 0.
let d = clock.observe(&key(0));
assert!(d.open_new && !d.skip && d.cut_previous.is_none());

// A keyframe before the target does not cut.
assert_eq!(clock.observe(&key(1000)).cut_previous, None);

// A keyframe at/after the target cuts the previous segment.
let d = clock.observe(&key(2000));
assert_eq!(d.cut_previous, Some(2.0));
assert!(d.open_new);

Implementations

impl SegmentClock

pub fn new(target_secs: u64) -> Self

A clock targeting target_secs-long segments (minimum 1 second).

pub fn is_open(&self) -> bool

Whether a segment is currently open.

pub fn observe(&mut self, frame: &MediaFrame) -> SegmentDecision

Feed one frame and learn what to do with it (call before writing it).

pub fn flush(&mut self) -> Option<f64>

Close any open segment at end-of-stream, returning its duration in seconds (or None if no segment is open).

Trait Implementations

impl Clone for SegmentClock

fn clone(&self) -> SegmentClock

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SegmentClock

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

Formats the value using the given formatter.