Class: Concurrent::EventMachineDeferProxy

Inherits:
Object
  • Object
show all
Defined in:
lib/concurrent/event_machine_defer_proxy.rb

Instance Method Summary collapse

Instance Method Details

#<<(block) ⇒ Object 



17
18
19
20
 
# File 'lib/concurrent/event_machine_defer_proxy.rb', line 17

def <<(block)
  EventMachine.defer(block)
  return self
end

#post(*args, &block) ⇒ Object 



7
8
9
10
11
12
13
14
15
 
# File 'lib/concurrent/event_machine_defer_proxy.rb', line 7

def post(*args, &block)
  if args.empty?
    EventMachine.defer(block)
  else
    new_block = proc{ block.call(*args) }
    EventMachine.defer(new_block)
  end
  return true
end