Struct ChannelBridgeHandler

pub struct ChannelBridgeHandler<H: ExchangeHandler, R: MessageRouter> { /* private fields */ }

Channel bridge handler

Implementations

impl<H: ExchangeHandler, R: MessageRouter> ChannelBridgeHandler<H, R>

pub fn new(inner: H, router: R) -> Self

Create a new channel bridge handler

pub fn register_subscription( &self, key: String, sender: UnboundedSender<Box<dyn Any + Send>>, subscription_type: SubscriptionType, )

Register a subscription channel

pub fn unregister_subscription(&self, key: &str) -> Option<SubscriptionChannel>

Unregister a subscription

pub fn subscription_count(&self) -> usize

Get the number of active subscriptions

pub fn clear_subscriptions(&self)

Clear all subscriptions

pub const fn inner(&self) -> &H

Get inner handler reference

pub const fn inner_mut(&mut self) -> &mut H

Get inner handler mutable reference

Trait Implementations

impl<H: ExchangeHandler, R: MessageRouter> ExchangeHandler for ChannelBridgeHandler<H, R>

fn exchange(&self) -> Exchange

Get the exchange type

fn get_subscriptions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get subscription messages

fn authenticate<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<Option<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle authentication if required

fn requires_auth(&self) -> bool

Check if the connection needs authentication

fn get_heartbeat(&self) -> Option<Message>

Get heartbeat message if required

fn heartbeat_interval(&self) -> Option<Duration>

Get heartbeat interval

impl<H: ExchangeHandler, R: MessageRouter> MessageHandler for ChannelBridgeHandler<H, R>

fn on_message<'life0, 'async_trait>( &'life0 mut self, message: Message, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a received message

fn on_connected<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle connection established

fn on_disconnected<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle connection closed

fn on_error<'life0, 'async_trait>( &'life0 mut self, error: WebSocketError, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle errors

fn set_sender(&mut self, _sender: UnboundedSender<Message>)

Set the sender for outgoing messages (optional, default implementation does nothing)

fn send_message(&self, _message: Message) -> WebSocketResult<()>

Send a message through the WebSocket (optional, default implementation returns error)