Class: Dashing::EventsController
- Inherits:
-
ApplicationController
- Object
- ActionController::Base
- ApplicationController
- Dashing::EventsController
- Includes:
- ActionController::Live
- Defined in:
- app/controllers/dashing/events_controller.rb
Instance Method Summary collapse
Instance Method Details
#index ⇒ Object
7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 |
# File 'app/controllers/dashing/events_controller.rb', line 7 def index response.headers['Content-Type'] = 'text/event-stream' response.headers['X-Accel-Buffering'] = 'no' @redis = Dashing.redis @redis.psubscribe("#{Dashing.config.redis_namespace}.*") do |on| on. do |pattern, event, data| response.stream.write("data: #{data}\n\n") end end rescue IOError logger.info "[Dashing][#{Time.now.utc.to_s}] Stream closed" ensure @redis.quit response.stream.close end |