Struct RtmpRoute 

pub struct RtmpRoute { /* private fields */ }

An RTMP push-ingest route: binds listen once and accepts publishers against it, gated by an optional app/stream_key (see Self::with_app/Self::with_stream_key). Replaces the pre-#805 task-4 RtmpSource; run_rtmp is the new, Listener-backed drive loop.

Implementations

impl RtmpRoute

pub fn new(name: impl Into<String>, listen: impl Into<String>) -> Self

Build a route listening on listen (e.g. "0.0.0.0:1935", or "127.0.0.1:0" for an ephemeral test port).

pub fn with_timeouts(self, timeouts: IngestTimeouts) -> Self

Overrides the default IngestTimeouts: connect bounds how long a still-establishing session (no Sample observed yet) may sit before HandshakePolicy::establish_by reaps it; read bounds every individual RtmpConnection::next_events call.

pub fn with_app(self, app: Option<String>) -> Self

Requires the publisher’s connect app name to match exactly, if set — enforced by RtmpIngestSession::feed once the first Connected { app } event arrives.

pub fn with_stream_key(self, stream_key: Option<String>) -> Self

Requires the publisher’s publish stream key to match exactly, if set — passed straight through as ServerConfig::expected_stream_key, so a mismatched key is rejected by the sans-IO session itself (NetStream.Publish.BadName) before this source ever sees a Publish/Media event.

pub fn with_max_sessions(self, max_sessions: usize) -> Self

Overrides DEFAULT_RTMP_MAX_SESSIONS — the Listener::max_sessions bound.

Trait Implementations

impl Debug for RtmpRoute

Manual Debug (rather than #[derive(Debug)]), mirroring crate::source::ts_http::TsHttpRoute’s: stream_key is redacted even though it’s a shared secret rather than a password, for the same reason — it should never turn up verbatim in a log line.

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

Formats the value using the given formatter.

impl Source for RtmpRoute

fn stream_name(&self) -> &str

Human-readable stream name (e.g. the RTSP URL or config-file key).