lib/rrj/janus/processus/event.rb in ruby_rabbitmq_janus-1.2.3.pre.53 vs lib/rrj/janus/processus/event.rb in ruby_rabbitmq_janus-1.2.3
- old
+ new
@@ -14,13 +14,10 @@
class Event < Concurrency
include Singleton
# Create a thred for execute a block code in a thread
#
- # @param [Proc] block Block code for execute action when queue
- # standard 'from-janus' receive a message.
- #
- # @return [Thread] It's a thread who listen queue and execute action
+ # @yield Send to publisher the actions when a Janus event is received
def run(&block)
thread.join
Thread.new do
loop { thread.thread_variable_get(:publish).listen_events(&block) }
end