aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_cable/channel/redis.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/action_cable/channel/redis.rb')
-rw-r--r--lib/action_cable/channel/redis.rb37
1 files changed, 0 insertions, 37 deletions
diff --git a/lib/action_cable/channel/redis.rb b/lib/action_cable/channel/redis.rb
deleted file mode 100644
index 0f77dc0418..0000000000
--- a/lib/action_cable/channel/redis.rb
+++ /dev/null
@@ -1,37 +0,0 @@
-module ActionCable
- module Channel
- module Redis
- extend ActiveSupport::Concern
-
- included do
- on_unsubscribe :unsubscribe_from_all_channels
- delegate :pubsub, to: :connection
- end
-
- def subscribe_to(redis_channel, callback = nil)
- callback ||= default_subscription_callback(redis_channel)
- @_redis_channels ||= []
- @_redis_channels << [ redis_channel, callback ]
-
- pubsub.subscribe(redis_channel, &callback)
- logger.info "#{channel_name} subscribed to broadcasts from #{redis_channel}"
- end
-
- def unsubscribe_from_all_channels
- if @_redis_channels
- @_redis_channels.each do |redis_channel, callback|
- pubsub.unsubscribe_proc(redis_channel, callback)
- logger.info "#{channel_name} unsubscribed to broadcasts from #{redis_channel}"
- end
- end
- end
-
- protected
- def default_subscription_callback(channel)
- -> (message) do
- transmit ActiveSupport::JSON.decode(message), via: "broadcast from #{channel}"
- end
- end
- end
- end
-end