Struct WebSocketConfig 

pub struct WebSocketConfig<'a, B>
where
    B: BroadcastTypeTrait,
{ /* private fields */ }

Configuration for a WebSocket connection.

This struct encapsulates all necessary parameters for setting up and managing a WebSocket connection, including context, buffer sizes, capacity, broadcast type, and hook handlers for different lifecycle events.

Type Parameters

• B: The type used for broadcast keys, which must implement BroadcastTypeTrait.

Implementations

impl<'a, B> WebSocketConfig<'a, B>

where B: BroadcastTypeTrait,

pub fn new(context: &'a mut Context) -> WebSocketConfig<'a, B>

Creates a new WebSocket configuration with the given context.

Arguments

• &mut Context - The context object to associate with the WebSocket.

Returns

• WebSocketConfig<B> - A new WebSocket configuration instance.

impl<'a, B> WebSocketConfig<'a, B>

where B: BroadcastTypeTrait,

pub fn set_capacity(self, capacity: usize) -> WebSocketConfig<'a, B>

Sets the capacity for the broadcast sender.

Arguments

• Capacity - The desired capacity.

Returns

• WebSocketConfig<B> - The modified WebSocket configuration instance.

pub fn set_context(self, context: &'a mut Context) -> WebSocketConfig<'a, B>

Sets the context for the WebSocket connection.

Arguments

• &mut Context - The context object to associate with the WebSocket.

Returns

• WebSocketConfig<B> - The modified WebSocket configuration instance.

pub fn set_broadcast_type( self, broadcast_type: BroadcastType<B>, ) -> WebSocketConfig<'a, B>

Sets the broadcast type for the WebSocket connection.

Arguments

• BroadcastType<B> - The broadcast type to use for this WebSocket.

Returns

• WebSocketConfig<B> - The modified WebSocket configuration instance.

pub fn get_context(&mut self) -> &mut Context

Retrieves a reference to the context associated with this configuration.

Returns

• &mut Context - A reference to the context object.

pub fn get_capacity(&self) -> usize

Retrieves the capacity configured for the broadcast sender.

Returns

• Capacity - The capacity.

pub fn get_broadcast_type(&self) -> &BroadcastType<B>

Retrieves a reference to the broadcast type configured for this WebSocket.

Returns

• &BroadcastType<B> - A reference to the broadcast type object.

pub fn set_connected_hook<S>(self) -> WebSocketConfig<'a, B>

where S: ServerHook,

Sets the connected hook handler.

This hook is executed when the WebSocket connection is established.

Type Parameters

• S: The hook type, which must implement ServerHook.

Returns

The modified WebSocketConfig instance.

Examples

struct MyConnectedHook;
impl ServerHook for MyConnectedHook {
    async fn new(_ctx: &Context) -> Self { Self }
    async fn handle(self, ctx: &Context) { /* ... */ }
}

let config = WebSocketConfig::new()
    .set_connected_hook::<MyConnectedHook>();

pub fn set_request_hook<S>(self) -> WebSocketConfig<'a, B>

where S: ServerHook,

Sets the request hook handler.

This hook is executed when a new request is received on the WebSocket.

Type Parameters

• S: The hook type, which must implement ServerHook.

Returns

The modified WebSocketConfig instance.

Examples

struct MyRequestHook;
impl ServerHook for MyRequestHook {
    async fn new(_ctx: &Context) -> Self { Self }
    async fn handle(self, ctx: &Context) { /* ... */ }
}

let config = WebSocketConfig::new()
    .set_request_hook::<MyRequestHook>();

pub fn set_sended_hook<S>(self) -> WebSocketConfig<'a, B>

where S: ServerHook,

Sets the sended hook handler.

This hook is executed after a message has been successfully sent over the WebSocket.

Type Parameters

• S: The hook type, which must implement ServerHook.

Returns

The modified WebSocketConfig instance.

Examples

struct MySendedHook;
impl ServerHook for MySendedHook {
    async fn new(_ctx: &Context) -> Self { Self }
    async fn handle(self, ctx: &Context) { /* ... */ }
}

let config = WebSocketConfig::new()
    .set_sended_hook::<MySendedHook>();

pub fn set_closed_hook<S>(self) -> WebSocketConfig<'a, B>

where S: ServerHook,

Sets the closed hook handler.

This hook is executed when the WebSocket connection is closed.

Type Parameters

• S: The hook type, which must implement ServerHook.

Returns

The modified WebSocketConfig instance.

Examples

struct MyClosedHook;
impl ServerHook for MyClosedHook {
    async fn new(_ctx: &Context) -> Self { Self }
    async fn handle(self, ctx: &Context) { /* ... */ }
}

let config = WebSocketConfig::new()
    .set_closed_hook::<MyClosedHook>();

pub fn get_connected_hook( &self, ) -> &Arc<dyn Fn(&mut Context) -> Pin<Box<dyn Future<Output = ()> + Send>> + Sync + Send>

Retrieves a reference to the connected hook handler.

Returns

• &ServerHookHandler - A reference to the connected hook handler.

pub fn get_request_hook( &self, ) -> &Arc<dyn Fn(&mut Context) -> Pin<Box<dyn Future<Output = ()> + Send>> + Sync + Send>

Retrieves a reference to the request hook handler.

Returns

• &ServerHookHandler - A reference to the request hook handler.

pub fn get_sended_hook( &self, ) -> &Arc<dyn Fn(&mut Context) -> Pin<Box<dyn Future<Output = ()> + Send>> + Sync + Send>

Retrieves a reference to the sended hook handler.

Returns

• &ServerHookHandler - A reference to the sended hook handler.

pub fn get_closed_hook( &self, ) -> &Arc<dyn Fn(&mut Context) -> Pin<Box<dyn Future<Output = ()> + Send>> + Sync + Send>

Retrieves a reference to the closed hook handler.

Returns

• &ServerHookHandler - A reference to the closed hook handler.