Struct RtmpHandler 

pub struct RtmpHandler { /* private fields */ }

Available on crate features ingest and rtmp only.

RTMP protocol handler. One instance serves an address; each connection is an independent publish or play session.

Publish (ingest) works through the ProtocolHandler contract alone. Play (egress) additionally needs read access to live streams, which run does not provide, so supply a PlaybackRegistry via with_playback (the bundled Engine implements both). Without it, play requests are answered with a failure status.

Implementations

impl RtmpHandler

pub fn new(addr: SocketAddr) -> Self

Create a handler bound to addr (typically 0.0.0.0:1935).

pub fn max_connections(self, max: usize) -> Self

Cap the number of concurrent connections (default 1024).

pub fn with_playback(self, playback: Arc<dyn PlaybackRegistry>) -> Self

Enable play (egress) by providing a PlaybackRegistry to resolve live streams from. Pass the same engine you publish into.

Trait Implementations

impl ProtocolHandler for RtmpHandler

fn name(&self) -> &'static str

Human-readable name (e.g. "rtmp", "hls").

fn run<'life0, 'async_trait>( &'life0 self, registry: Arc<dyn PublishRegistry>, shutdown: CancellationToken, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start accepting connections. Implementations should run until the provided shutdown token is cancelled, resolving incoming connections to a StreamKey and forwarding frames through registry.