Struct ChainedHandler 

pub struct ChainedHandler<H1, H2> { /* private fields */ }

A handler wrapper that chains multiple handlers

Implementations

impl<H1, H2> ChainedHandler<H1, H2>

where H1: RtmpHandler, H2: RtmpHandler,

pub fn new(first: H1, second: H2) -> Self

Trait Implementations

impl<H1, H2> RtmpHandler for ChainedHandler<H1, H2>

where H1: RtmpHandler, H2: RtmpHandler,

fn on_connection<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

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

Called when a new TCP connection is established

fn on_connect<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, params: &'life2 ConnectParams, ) -> Pin<Box<dyn Future<Output = AuthResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called on RTMP ‘connect’ command

fn on_publish<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, params: &'life2 PublishParams, ) -> Pin<Box<dyn Future<Output = AuthResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called on ‘publish’ command

fn on_disconnect<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 SessionContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when the connection closes

fn on_handshake_complete<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 SessionContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called after successful handshake, before connect command

fn on_fc_publish<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 SessionContext, _stream_key: &'life2 str, ) -> Pin<Box<dyn Future<Output = AuthResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called on FCPublish command (OBS/Twitch compatibility)

fn on_play<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 SessionContext, _params: &'life2 PlayParams, ) -> Pin<Box<dyn Future<Output = AuthResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called on ‘play’ command

fn on_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, _metadata: &'life2 HashMap<String, AmfValue>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

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

fn on_media_tag<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, _tag: &'life2 FlvTag, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

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

fn on_video_frame<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, _frame: &'life2 H264Data, _timestamp: u32, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called for each video frame (when MediaDeliveryMode includes ParsedFrames)

fn on_audio_frame<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, _frame: &'life2 AacData, _timestamp: u32, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called for each audio frame (when MediaDeliveryMode includes ParsedFrames)

fn on_keyframe<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, _timestamp: u32, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a keyframe is received

fn on_publish_stop<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when the publish stream ends

fn on_play_stop<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when the play stream ends

fn on_pause<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a subscriber pauses playback

fn on_unpause<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 StreamContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called when a subscriber resumes playback

fn media_delivery_mode(&self) -> MediaDeliveryMode

Get the media delivery mode for this handler

fn on_stats_update<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 SessionContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Called periodically with stats update