module Sinatra::PubSub::Helpers
Public Instance Methods
publish(channel, message)
click to toggle source
# File lib/sinatra/pubsub/helpers.rb, line 8 def publish(channel, message) Redis.publish(channel, message.to_json) end
publish_all(message)
click to toggle source
# File lib/sinatra/pubsub/helpers.rb, line 12 def publish_all(message) publish(:all, message) end
subscribe()
click to toggle source
# File lib/sinatra/pubsub/helpers.rb, line 16 def subscribe Thread.abort_on_exception = true trap('TERM') do Stream.disable! Process.kill('INT', $$) end EM::next_tick do Thread.new do Redis.subscribe end end end