Struct 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<MaybeRustlsStream<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 fn set_tls(self, tls: Option<TlsAcceptor>) -> Self

设置TCP server 连接事件

pub fn set_config(self, config: WebSocketConfig) -> Self

设置config

pub fn set_load_timeout(self, load_timeout_secs: u64) -> Self

设置等待websocket hand accept 加载 等待时间

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

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