Struct LoggingHandler 

pub struct LoggingHandler;

A simple handler that accepts all connections and logs events

Trait Implementations

impl RtmpHandler for LoggingHandler

async fn on_connection(&self, ctx: &SessionContext) -> bool

Called when a new TCP connection is established

async fn on_connect( &self, ctx: &SessionContext, params: &ConnectParams, ) -> AuthResult

Called on RTMP ‘connect’ command

async fn on_publish( &self, ctx: &SessionContext, params: &PublishParams, ) -> AuthResult

Called on ‘publish’ command

async fn on_metadata( &self, ctx: &StreamContext, metadata: &HashMap<String, AmfValue>, )

Called when stream metadata is received (@setDataFrame/onMetaData)

async fn on_disconnect(&self, ctx: &SessionContext)

Called when the connection closes

fn on_handshake_complete( &self, _ctx: &SessionContext, ) -> impl Future<Output = ()> + Send

Called after successful handshake, before connect command

fn on_fc_publish( &self, _ctx: &SessionContext, _stream_key: &str, ) -> impl Future<Output = AuthResult> + Send

Called on FCPublish command (OBS/Twitch compatibility)

fn on_play( &self, _ctx: &SessionContext, _params: &PlayParams, ) -> impl Future<Output = AuthResult> + Send

Called on ‘play’ command

fn on_media_tag( &self, _ctx: &StreamContext, _tag: &FlvTag, ) -> impl Future<Output = bool> + Send

Called for each raw FLV tag (when MediaDeliveryMode includes RawFlv)

fn on_video_frame( &self, _ctx: &StreamContext, _frame: &H264Data, _timestamp: u32, ) -> impl Future<Output = ()> + Send

Called for each video frame (when MediaDeliveryMode includes ParsedFrames)

fn on_audio_frame( &self, _ctx: &StreamContext, _frame: &AacData, _timestamp: u32, ) -> impl Future<Output = ()> + Send

Called for each audio frame (when MediaDeliveryMode includes ParsedFrames)

fn on_keyframe( &self, _ctx: &StreamContext, _timestamp: u32, ) -> impl Future<Output = ()> + Send

Called when a keyframe is received

fn on_publish_stop( &self, _ctx: &StreamContext, ) -> impl Future<Output = ()> + Send

👎Deprecated since 0.3.0: Use on_unpublish instead

Called when the publish stream ends

fn on_unpublish(&self, _ctx: &StreamContext) -> impl Future<Output = ()> + Send

Called when the publish stream ends

fn on_play_stop(&self, _ctx: &StreamContext) -> impl Future<Output = ()> + Send

Called when the play stream ends

fn on_pause(&self, _ctx: &StreamContext) -> impl Future<Output = ()> + Send

Called when a subscriber pauses playback

fn on_unpause(&self, _ctx: &StreamContext) -> impl Future<Output = ()> + Send

Called when a subscriber resumes playback

fn media_delivery_mode(&self) -> MediaDeliveryMode

Get the media delivery mode for this handler

fn on_stats_update( &self, _ctx: &SessionContext, ) -> impl Future<Output = ()> + Send

Called periodically with stats update