Struct MockConnectionFactory 

pub struct MockConnectionFactory { /* private fields */ }

Mock peer connection factory

Creates mock data channels instead of real WebRTC connections. Uses a global registry to connect offer/answer sides.

Implementations

impl MockConnectionFactory

pub fn new(peer_id: String, latency_ms: u64) -> Self

Create a new mock connection factory

pub fn new_with_latency_mode( peer_id: String, latency_ms: u64, latency_mode: MockLatencyMode, ) -> Self

Create a mock connection factory with explicit latency mode.

Trait Implementations

impl PeerLinkFactory for MockConnectionFactory

fn create_offer<'life0, 'life1, 'async_trait>( &'life0 self, target_peer_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(Arc<dyn PeerLink>, String), TransportError>> + Send + 'async_trait>>

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

Create an outgoing negotiated link. Returns (our_link, offer_sdp).

fn accept_offer<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _from_peer_id: &'life1 str, offer_sdp: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(Arc<dyn PeerLink>, String), TransportError>> + Send + 'async_trait>>

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

Accept an incoming negotiated link. Returns (our_link, answer_sdp).

fn handle_answer<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, target_peer_id: &'life1 str, _answer_sdp: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Arc<dyn PeerLink>, TransportError>> + Send + 'async_trait>>

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

Complete a link after receiving the answer.

fn handle_candidate<'life0, 'life1, 'async_trait>( &'life0 self, _peer_id: &'life1 str, _candidate: IceCandidate, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Apply a trickle candidate update for an in-flight link, if relevant.

fn handle_candidates<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 str, candidates: Vec<IceCandidate>, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Apply a batch of trickle candidate updates.

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

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

Drop any factory-owned state for a peer that has been removed.