Struct DefaultNetworkEventProcessor 

pub struct DefaultNetworkEventProcessor { /* private fields */ }

Default network event processor implementation

Implementations

impl DefaultNetworkEventProcessor

pub fn new( signaling_client: Arc<dyn SignalingClient>, webrtc_coordinator: Option<Arc<WebRtcCoordinator>>, ) -> Self

pub fn new_with_debounce( signaling_client: Arc<dyn SignalingClient>, webrtc_coordinator: Option<Arc<WebRtcCoordinator>>, debounce_config: DebounceConfig, ) -> Self

Trait Implementations

impl NetworkEventProcessor for DefaultNetworkEventProcessor

fn process_network_available<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Process network available event

fn process_network_lost<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Process network lost event

fn process_network_type_changed<'life0, 'async_trait>( &'life0 self, is_wifi: bool, is_cellular: bool, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Process network type changed event

fn cleanup_connections<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Proactively clean up all connections

Differs from process_network_lost():

• No debounce check (proactive calls always execute)
• Intended for app lifecycle management, not network event response

fn process_network_recovery_action<'life0, 'async_trait>( &'life0 self, action: NetworkRecoveryAction, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Process the final action selected from a settled event batch.