Struct InnerSwarmCallback 

pub struct InnerSwarmCallback { /* private fields */ }

InnerSwarmCallback wraps SharedSwarmCallback with inner handling for a specific connection.

Implementations

impl InnerSwarmCallback

pub fn new( transport: Arc<SwarmTransport>, callback: SharedSwarmCallback, ) -> Self

Create a new InnerSwarmCallback with the provided transport and callback.

Trait Implementations

impl TransportCallback for InnerSwarmCallback

fn on_message<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, cid: &'life1 str, msg: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error>>> + Send + 'async_trait>>

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

This method is invoked on a binary message arrival over the data channel of webrtc.

fn on_peer_connection_state_change<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 str, s: WebrtcConnectionState, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error>>> + Send + 'async_trait>>

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

This method is invoked when the state of connection has changed.

fn on_data_channel_open<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error>>> + Send + 'async_trait>>

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

Notify the data channel is open.

fn on_data_channel_close<'life0, 'life1, 'async_trait>( &'life0 self, cid: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error>>> + Send + 'async_trait>>

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

Notify the data channel is closed. This is a reliable, prompt signal that the peer has gone (e.g. it closed the connection): unlike the ICE Disconnected state it does not fire on transient blips, so the swarm can use it to tear the connection down without waiting for Failed.