Struct DashifIngestSession 

pub struct DashifIngestSession { /* private fields */ }

Sans-IO ingest session for one DASH-IF Interface-1 publishing point.

Implementations

impl DashifIngestSession

pub fn grouping(&self) -> Option<ManifestGrouping>

The manifest grouping learned from a successful Manifest, if any.

pub fn config(&self) -> DashifIngestConfig

The limits this session was configured with.

pub fn new(config: DashifIngestConfig) -> Self

Construct an empty session with config. No manifest has been received yet.

pub fn begin_segment( &mut self, rep: impl AsRef<str>, number: Option<u64>, time: Option<u64>, ) -> Result<SegmentHandle, SessionError>

pub fn push_segment_bytes( &mut self, handle: &mut SegmentHandle, bytes: &[u8], ) -> Result<(), SessionError>

pub fn finish_segment( &mut self, handle: SegmentHandle, ) -> Result<(), SessionError>

pub fn abort_segment(&mut self, handle: SegmentHandle)

Discard a partially-streamed segment (P3b): drop any buffered remainder without emitting it. Chunks already published stay published.

Trait Implementations

impl IngestSession for DashifIngestSession

type Request = !

What poll_transmit hands back — opaque to the plane, deliberately: see the module docs for why this is not a fixed enum. A byte-stream source (RTSP/RTMP/SRT/ TS-*) sets this to bytes::Bytes; a pull source sets it to its own protocol’s action type (e.g. hls_runtime::client::Action).

fn poll_transmit(&mut self) -> Option<Self::Request>

The next outbound request this session wants performed — bytes written to an already-open connection, or (for a pull source) a fetch/wait action for the driver to carry out.

impl Stage for DashifIngestSession

type In<'a> = IngestObject<'a>

The shape of input this stage consumes via feed.

type Out = SessionEvent

The type of output this stage produces, pulled via poll.

type Error = SessionError

The error type this stage returns from feed and finish.

fn feed( &mut self, input: Self::In<'_>, _now: Timestamp, ) -> Result<(), Self::Error>

Feed more input into the stage at time now.

fn poll(&mut self) -> Option<Self::Out>

Pull one unit of ready output, if any is available.

fn finish(&mut self) -> Result<(), Self::Error>

Signal that no more input will ever be fed.

fn demand(&self) -> Demand

A hint about how much more input this stage would like right now.

fn next_deadline(&self) -> Option<Timestamp>

The next point in time (on the same clock as feed’s now) at which this stage has time-driven work to do, if any.

fn on_deadline(&mut self, _now: Timestamp)

Let the stage act purely on the passage of time (no new bytes), e.g. a rate-scheduled re-emission or a timeout.