Struct WsIoClientBuilder 

pub struct WsIoClientBuilder { /* private fields */ }

Implementations

impl WsIoClientBuilder

pub fn build(self) -> WsIoClient

pub fn init_handler_timeout(self, duration: Duration) -> Self

pub fn init_packet_timeout(self, duration: Duration) -> Self

pub fn on_session_close<H, Fut>(self, handler: H) -> Self

where H: Fn(Arc<WsIoClientSession>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

pub fn on_session_close_handler_timeout(self, duration: Duration) -> Self

pub fn on_session_ready<H, Fut>(self, handler: H) -> Self

where H: Fn(Arc<WsIoClientSession>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

pub fn packet_codec(self, packet_codec: WsIoPacketCodec) -> Self

pub fn ping_interval(self, duration: Duration) -> Self

pub fn ready_packet_timeout(self, duration: Duration) -> Self

pub fn reconnect_delay(self, delay: Duration) -> Self

pub fn request_path(self, request_path: impl AsRef<str>) -> Self

pub fn websocket_config(self, websocket_config: WebSocketConfig) -> Self

pub fn websocket_config_mut<F: FnOnce(&mut WebSocketConfig)>(self, f: F) -> Self

pub fn with_init_handler<H, Fut, D, R>(self, handler: H) -> WsIoClientBuilder

where H: Fn(Arc<WsIoClientSession>, Option<D>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Option<R>>> + Send + 'static, D: DeserializeOwned + Send + 'static, R: Serialize + Send + 'static,