Struct RtmpConnection 

pub struct RtmpConnection { /* private fields */ }

Available on crate feature tokio only.

One accepted RTMP connection: a TcpStream driving a ServerSession.

next_events is the whole surface: read a chunk, drive the session, write the reply, return the events.

Implementations

impl RtmpConnection

pub fn peer_addr(&self) -> Result<SocketAddr>

The remote address of the connected publisher.

pub async fn next_events(&mut self) -> Result<Option<Vec<ServerEvent>>>

Reads one chunk from the socket, drives ServerSession::handle_data, writes the reply bytes back (all of them), and returns the resulting events.

Returns Ok(None) when the connection is finished: the peer closed the socket (clean EOF), or the most recent batch of events included ServerEvent::Eof (so the caller sees that final batch once, then None on the next call). Once a call returns None, every subsequent call also returns None without reading the socket again.

Errors

An io::Error from the underlying socket read/write, or a mapped RtmpError (kind io::ErrorKind::InvalidData) from ServerSession::handle_data. On an RtmpError the session is unrecoverable (per handle_data’s own doc): this connection is torn down immediately — marked closed and not driven further, even if the caller keeps calling next_events.

Trait Implementations

impl Debug for RtmpConnection

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

Formats the value using the given formatter.