Struct TcpManager 

pub struct TcpManager { /* private fields */ }

Actor-style TCP manager. Drop the handle (or call Self::shutdown) to stop it.

Implementations

impl TcpManager

pub fn spawn() -> (Self, UnboundedReceiver<IoEvent>)

Spawn the manager and return the command handle + event stream.

pub fn bind(&self, addr: SocketAddr) -> Result<()>

pub fn connect(&self, addr: SocketAddr) -> Result<()>

Initiate an outbound connection. On success the manager publishes IoEvent::Connected { id, peer }; on failure it publishes IoEvent::Error { reason }.

pub fn send_bytes(&self, id: ConnId, bytes: Vec<u8>) -> Result<()>

pub fn close(&self, id: ConnId) -> Result<()>

pub fn shutdown(&self)