Struct websocket_server_async::Builder

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

websocket server builder

Implementations

impl<I, R, A, T> Builder<I, R, A, T> where
    I: Fn(SplitStream<WebSocketStream<TcpStream>>, Arc<Actor<WSPeer>>, T) -> R + Send + Sync + 'static,
    R: Future<Output = Result<()>> + Send + 'static,
    A: ToSocketAddrs,
    T: Clone + Send + 'static, 

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

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

设置websocket server 输入事件

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

设置TCP server 连接事件

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

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