# File 'lib/sinatra/pubsub/helpers.rb', line 8defpublish(channel,message)Redis.publish(channel,message.to_json)end
#publish_all(message) ⇒ Object
12
13
14
# File 'lib/sinatra/pubsub/helpers.rb', line 12defpublish_all(message)publish(:all,message)end
#subscribe ⇒ Object
16
17
18
19
20
21
22
23
24
25
26
27
28
29
# File 'lib/sinatra/pubsub/helpers.rb', line 16defsubscribeThread.abort_on_exception=truetrap('TERM')doStream.disable!Process.kill('INT',$$)endEM::next_tickdoThread.newdoRedis.subscribeendendend