hls_runtime/client/

mod.rs

//! LL-HLS playback client engine — a sans-IO Low-Latency HLS (RFC 8216bis)
//! client (issue #717, slices 2-4; the `client` module of `hls-runtime` — see
//! `docs/superpowers/specs/2026-07-18-multimux-hub-design.md`).
//!
//! [`HlsClient`] is a driveable, caller-driven state machine — the same
//! sans-IO shape as `srt-runtime` (issue #565): the core never opens a socket
//! or reads a clock. The caller drains [`Action`]s (what to fetch, and how),
//! performs the IO itself, and feeds the response back in via
//! [`HlsClient::on_playlist`] / [`HlsClient::on_resource`] /
//! [`HlsClient::on_error`]; decoded [`Output`]s (the init segment, then
//! ordered access units) drain out via [`HlsClient::next_output`].
//!
//! # Reuse, not re-description
//!
//! This module defines **no playlist model of its own**. Parsing is
//! [`broadcast_hls::MediaPlaylist::parse`] (issue #717 slice 1 — the
//! symmetric inverse of the LL-HLS origin's own `to_m3u8()` renderer, so
//! origin and client share one wire model); demuxing a fetched CMAF part or
//! segment into access units is [`transmux::Fmp4Demux`]. `client` holds only
//! the client **engine**: the reload scheduler, the fetch pipeline
//! (prefetch/byte-range/dedup), and the output ordering — see
//! [`HlsClient`]'s docs for the full behaviour.
//!
//! # Zero IO in the core
//!
//! No `tokio`/`reqwest`/socket dependency in [`HlsClient`] itself, ever —
//! it is driveable by hand (see the crate's `hls-runtime/tests/it/origin_loop.rs` for a
//! complete in-process example against a real
//! `transmux::ll_hls::LlHlsSegmenter` origin) with zero IO dependencies at
//! all (verified by the `--no-default-features` gate).
//!
//! # Example
//!
//! ```
//! use hls_runtime::client::{Action, HlsClient};
//!
//! let mut client = HlsClient::new(hls_runtime::client::HlsClientConfig::new("http://origin/live/stream.m3u8"));
//! // The caller performs this GET; here we just inspect the first action.
//! match client.poll() {
//!     Some(Action::FetchPlaylist { url, blocking, .. }) => {
//!         assert_eq!(url, "http://origin/live/stream.m3u8");
//!         assert!(blocking.is_none()); // nothing fetched yet, so no LL info.
//!     }
//!     other => panic!("unexpected first action: {other:?}"),
//! }
//! ```

mod action;
mod engine;
mod error;
mod output;
mod url;

pub use action::{Action, BlockingReload, KeyId, ResourceId};
pub use engine::{HlsClient, HlsClientConfig, choose_variant};
pub use error::{Error, Result};
pub use output::{MasterSelection, Output, RenditionInfo, VariantInfo, VariantPolicy};