Struct webrtc_util::conn::conn_bridge::Bridge

pub struct Bridge { /* fields omitted */ }

Bridge represents a network between the two endpoints.

Implementations

impl Bridge

pub fn new(
    loss_chance: u8,
    filter_cb0: Option<Box<dyn Fn(&Bytes) -> bool + Send + Sync>>,
    filter_cb1: Option<Box<dyn Fn(&Bytes) -> bool + Send + Sync>>
) -> (Arc<Bridge>, impl Conn, impl Conn)

pub async fn len(&self, id: usize) -> usize

Len returns number of queued packets.

pub async fn push(&self, b: &[u8], id: usize) -> Result<usize>

pub async fn reorder(&self, id: usize) -> bool

Reorder inverses the order of packets currently in the specified queue.

pub async fn drop_offset(&self, id: usize, offset: usize, n: usize)

Drop drops the specified number of packets from the given offset index of the specified queue.

pub async fn drop_next_nwrites(&self, id: usize, n: usize)

drop_next_nwrites drops the next n packets that will be written to the specified queue.

pub async fn reorder_next_nwrites(&self, id: usize, n: usize)

reorder_next_nwrites drops the next n packets that will be written to the specified queue.

pub async fn clear(&self)

pub async fn tick(&self) -> usize

Tick attempts to hand a packet from the queue for each directions, to readers, if there are waiting on the queue. If there’s no reader, it will return immediately.

pub async fn process(&self)

Process repeats tick() calls until no more outstanding packet in the queues.

Trait Implementations

impl Default for Bridge

fn default() -> Bridge

Returns the “default value” for a type.