Struct AddrEventManager 

pub struct AddrEventManager { /* private fields */ }

Implementations

impl AddrEventManager

Implementation of AddrEventManager for TCP listener (requires Clone on Authenticator and Bicrypter)

pub fn for_tcp_listener<A, B>( handle: Handle, max_outbound_queue: usize, listener: TcpListener, wire: Wire<A, B>, on_inbound_tx: Sender<(Msg, SocketAddr, Sender<Vec<u8>>)>, ) -> AddrEventManager

where A: Authenticator + Send + Sync + Clone + 'static, B: Bicrypter + Send + Sync + Clone + 'static,

impl AddrEventManager

Implementation of AddrEventManager for UDP stream

pub fn for_udp_socket<A, B>( handle: Handle, max_outbound_queue: usize, socket: UdpSocket, wire: Wire<A, B>, on_inbound_tx: Sender<(Msg, SocketAddr, Sender<(Vec<u8>, SocketAddr)>)>, ) -> AddrEventManager

where A: Authenticator + Send + Sync + 'static, B: Bicrypter + Send + Sync + 'static,

impl AddrEventManager

pub fn for_udp_socket_with_cloneable_wire<A, B>( handle: Handle, max_outbound_queue: usize, socket: UdpSocket, wire: Wire<A, B>, on_inbound_tx: Sender<(Msg, SocketAddr, Sender<(Vec<u8>, SocketAddr)>)>, ) -> AddrEventManager

where A: Authenticator + Send + Sync + Clone + 'static, B: Bicrypter + Send + Sync + Clone + 'static,

impl AddrEventManager

pub async fn send_to( &mut self, data: Vec<u8>, addr: SocketAddr, ) -> Result<(), (Vec<u8>, SocketAddr)>

pub async fn wait(self) -> Result<(), JoinError>