Struct tcpserver::TCPPeer

pub struct TCPPeer<T> {
    pub addr: SocketAddr,
    pub sender: Option<WriteHalf<T>>,
}

Fields

addr: SocketAddr

sender: Option<WriteHalf<T>>

Implementations

impl<T> TCPPeer<T> where
    T: AsyncRead + AsyncWrite + Send + 'static, 

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

创建一个TCP PEER

pub fn is_disconnect(&self) -> bool

是否断线

pub async fn send<'a>(&'a mut self, buff: &'a [u8]) -> Result<usize>

发送

pub async fn send_all<'a>(&'a mut self, buff: &'a [u8]) -> Result<()>

发送全部

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

flush

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

掐线