lib/rrj/janus/processus/event.rb in ruby_rabbitmq_janus-1.2.2 vs lib/rrj/janus/processus/event.rb in ruby_rabbitmq_janus-1.2.3.pre.53

- old
+ new

@@ -14,10 +14,13 @@ class Event < Concurrency include Singleton # Create a thred for execute a block code in a thread # - # @yield Send to publisher the actions when a Janus event is received + # @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 def run(&block) thread.join Thread.new do loop { thread.thread_variable_get(:publish).listen_events(&block) } end