Struct tcpserver::Builder

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

TCP server builder

Implementations

impl<I, R, A, T, B, C, IST> Builder<I, R, A, T, B, C, IST>

where I: Fn(ReadHalf<C>, Arc<Actor<TCPPeer<C>>>, 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, IST: Fn(TcpStream) -> B + Send + Sync + 'static,

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

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: IST) -> Self

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

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

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