Class: Salemove::ProcessHandler::CompositeProcess

Inherits:

Object

• Object
• Salemove::ProcessHandler::CompositeProcess

Defined in:

lib/salemove/process_handler/composite_process.rb

Instance Method Summary

• #add(process, service) ⇒ Object
• #block ⇒ Object
• #initialize(&block) ⇒ CompositeProcess constructor

  A new instance of CompositeProcess.

• #start ⇒ Object

Constructor Details

#initialize(&block) ⇒ CompositeProcess

Returns a new instance of CompositeProcess.

# File 'lib/salemove/process_handler/composite_process.rb', line 12

def initialize(&block)
  @process_spawners = []
  @monitor = CompositeProcessMonitor.new
  instance_eval &block if block_given?
end

Instance Method Details

#add(process, service) ⇒ Object

# File 'lib/salemove/process_handler/composite_process.rb', line 18

def add(process, service)
  @monitor.add process.process_monitor
  @process_spawners << Proc.new { process.spawn service, blocking: false }
end

#block ⇒ Object

# File 'lib/salemove/process_handler/composite_process.rb', line 29

def block
  sleep 1 while @monitor.running?
end

#start ⇒ Object

# File 'lib/salemove/process_handler/composite_process.rb', line 23

def start
  @process_spawners.each(&:call)
  @monitor.start
  block
end