Struct tcpserver::Builder

pub struct Builder<I, R, A, T, B, C> { /* fields omitted */ }

TCP server builder

Implementations

impl<I, R, A, T, B, C> Builder<I, R, A, T, B, C> where
    I: Fn(ReadHalf<C>, Arc<dyn IPeer>, T) -> R + Send + Sync + 'static,
    R: Future<Output = Result<()>> + Send + 'static,
    A: ToSocketAddrs,
    T: Clone + Send + 'static,
    B: Future<Output = Result<C>> + Send + 'static,
    C: AsyncRead + AsyncWrite + Send + 'static, 

pub fn new(addr: A) -> Builder<I, R, A, T, B, C>

pub fn set_input_event(self, f: I) -> Self

设置TCP server 输入事件

pub fn set_connect_event(self, c: ConnectEventType) -> Self

设置TCP server 连接事件

pub fn set_stream_init(self, c: StreamInitType<B>) -> Self

设置输入流类型,例如TCPStream,SSLStream or GZIPStream

pub async fn build(self) -> Arc<Actor<TCPServer<I, R, T, B, C>>>

生成TCPSERVER,如果没有设置 tcp input 将报错