class

ActionCable::SubscriptionAdapter::Redis

Inherits ActionCable::SubscriptionAdapter::Base < ActionCable::SubscriptionAdapter::PubsubAdapter < Reference < Object

Constructors

new(url : String = ENV.fetch("REDIS_URL", "redis:///"))
Source

Instance methods

broadcast(channel : String, payload : String) : Nil
Source
shutdown
Source
subscribe(channel : String, callback : Proc(String, Nil)) : Nil
Source
unsubscribe(channel : String, callback : Proc(String, Nil)) : Nil

Same Proc-identity deviation as Test/Async: drops every callback of the channel. The redis subscription itself stays (P0).

Source