struct Amber::WebSockets::SubscriptionManager

• Amber::WebSockets::SubscriptionManager
• Struct
• Value
• Object

Overview

SubscriptionManager manages the list of channel subscriptions for the socket connection. Also handles dispatching actions (messages) to the appropriate channel.

Errors in one channel are isolated and do not affect other channels or crash the socket connection. Errors are forwarded to the channel's on_error callback and to the socket's handle_error method for reporting.

Defined in:

amber/websockets/subscription_manager.cr

Constant Summary

Log = ::Log.for(self)

Constructors

• .new

Instance Method Summary

• #dispatch(client_socket, message)
• #initialize
• #subscriptions : Hash(String, Amber::WebSockets::Channel)
• #subscriptions=(subscriptions : Hash(String, Amber::WebSockets::Channel))

Constructor Detail

Instance Method Detail