class Dynflow::Flows::Concurrence

Protected Instance Methods

add_to_sequence(satisfying_flows, dependent_flow) click to toggle source
# File lib/dynflow/flows/concurrence.rb, line 7
def add_to_sequence(satisfying_flows, dependent_flow)
  if satisfying_flows.empty?
    self.sub_flows << dependent_flow
    return
  end
  extracted_flow = extract_flows(satisfying_flows)
  sequence       = Sequence.new([extracted_flow])

  self.sub_flows << sequence
  sequence << dependent_flow
end
extract_flows(extracted_sub_flows) click to toggle source
# File lib/dynflow/flows/concurrence.rb, line 19
def extract_flows(extracted_sub_flows)
  extracted_sub_flows.each do |sub_flow|
    self.sub_flows.delete(sub_flow)
  end

  return Concurrence.new(extracted_sub_flows)
end