Struct UtpSocket

pub struct UtpSocket<P: ConnectionPeer> { /* private fields */ }

Implementations

impl UtpSocket<SocketAddr>

pub async fn bind(addr: SocketAddr) -> Result<Self>

impl<P> UtpSocket<P>

where P: ConnectionPeer<Id: Unpin> + Unpin + 'static,

pub fn with_socket<S>(socket: S) -> Self

where S: AsyncUdpSocket<P> + 'static,

pub fn cid(&self, peer_id: P::Id, is_initiator: bool) -> ConnectionId<P::Id>

pub fn num_connections(&self) -> usize

Returns the number of connections currently open, both inbound and outbound.

pub async fn accept(&self, config: ConnectionConfig) -> Result<UtpStream<P>>

WARNING: only accept() or accept_with_cid() can be used in an application. they aren’t compatible to use interchangeably in a program

pub async fn accept_with_cid( &self, cid: ConnectionId<P::Id>, peer: Peer<P>, config: ConnectionConfig, ) -> Result<UtpStream<P>>

WARNING: only accept() or accept_with_cid() can be used in an application. they aren’t compatible to use interchangeably in a program

pub async fn connect( &self, peer: Peer<P>, config: ConnectionConfig, ) -> Result<UtpStream<P>>

pub async fn connect_with_cid( &self, cid: ConnectionId<P::Id>, peer: Peer<P>, config: ConnectionConfig, ) -> Result<UtpStream<P>>

Trait Implementations

impl<P: ConnectionPeer> Drop for UtpSocket<P>

fn drop(&mut self)

Executes the destructor for this type.