Struct NetworkStream 

pub struct NetworkStream { /* private fields */ }

TCP network stream for distributed rip/remux.

Implementations

impl NetworkStream

pub fn connect(addr: &str) -> Result<Self>

Connect to a remote listener for writing. Sends FMKV metadata header on first write.

pub fn meta(self, dt: &DiscTitle) -> Self

Set stream metadata (for write side). Returns self for chaining.

pub fn listen(addr: &str) -> Result<Self>

Listen for an incoming connection and read from it. Extracts FMKV metadata header from the sender.

Trait Implementations

impl Stream for NetworkStream

fn read(&mut self) -> Result<Option<PesFrame>>

Read the next frame, or Ok(None) at end of stream. Returns StreamWriteOnly (E9001) on a write-only sink.

fn write(&mut self, frame: &PesFrame) -> Result<()>

Write a frame to the sink. Returns StreamReadOnly (E9000) on a read-only source.

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

Finalize the stream: flush buffered frames, write any container index (MKV Cues), close the underlying file/socket. Idempotent for read-only streams (no-op).

fn info(&self) -> &DiscTitle

Stream metadata. Stable across reads — implementors must return a consistent reference for the lifetime of the stream.

fn codec_private(&self, _track: usize) -> Option<Vec<u8>>

Codec initialization data for a track (SPS/PPS, AC-3 fscod, etc.). None for tracks that don’t need codec_private (raw passthrough).

fn headers_ready(&self) -> bool

True when codec_private is available for every video track — callers buffer input frames until this flips, since some output formats (MKV) can’t write frames without codec init data.