Struct over_there_core::AddrEventManager

pub struct AddrEventManager { /* fields omitted */ }

Methods

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>