Sha256: 1ba7168996e80c05c02824f604a4967eb76ccb91f78011e91f53d43a1b434f65
Contents?: true
Size: 750 Bytes
Versions: 15
Compression:
Stored size: 750 Bytes
Contents
# frozen_string_literal: true
module Dynflow
module Flows
class Concurrence < AbstractComposed
protected
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
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
end
Registry.register!(Concurrence, 'C')
end
end
Version data entries
15 entries across 15 versions & 1 rubygems