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