Method: DaemonKit::EM.run

Defined in:
lib/daemon_kit/em.rb

.run(&block) ⇒ Object

Start a reactor, just like classical EM.run. If the block is provided, the method will block and call the provided block argument inside the running reactor. If the block argument is not provided the reactor will be started in a separate thread and the program will continue to run after the method. All the signal traps are configured to shutdown the reactor when the daemon exists.



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/daemon_kit/em.rb', line 19

def run(&block)
  if ::EM.reactor_running?
    DaemonKit.logger.warn "EventMachine reactor already running"
    block.call if block_given?

  else
    if block_given?
      ::EM.run { block.call }
    else
      Thread.main[:_dk_reactor] = Thread.new { EM.run {} }
      DaemonKit.trap( 'INT' ) { DaemonKit::EM.stop  }
      DaemonKit.trap( 'TERM' ) { DaemonKit::EM.stop }
    end
  end
end