Struct TCPPeer

pub struct TCPPeer<T> {
    pub addr: SocketAddr,
    pub sender: Sender<State>,
    /* private fields */
}

Fields

addr: SocketAddr

sender: Sender<State>

Implementations

impl<T> TCPPeer<T>

where T: AsyncRead + AsyncWrite + Send + 'static,

pub fn new(addr: SocketAddr, sender: WriteHalf<T>) -> Arc<TCPPeer<T>>

创建一个TCP PEER

pub fn addr(&self) -> SocketAddr

ipaddress

pub fn is_disconnect(&self) -> bool

是否断线

pub async fn send(&self, buff: Vec<u8>) -> Result<()>

发送

pub async fn send_all(&self, buff: Vec<u8>) -> Result<()>

发送全部

pub async fn flush(&self) -> Result<()>

flush

pub async fn disconnect(&self) -> Result<()>

掐线