class Rufus::Scheduler::EmScheduler

def trigger_job(blocking, &block)

'next_tick'. Else the block will get called via 'defer' (own thread).
If 'blocking' is set to true, the block will get called at the

def trigger_job(blocking, &block)
  m = blocking ? :next_tick : :defer
    #
    # :next_tick monopolizes the EM
    # :defer executes its block in another thread
  EM.send(m) { block.call }
end

Instance Methods