Struct rings_core::swarm::callback::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.