Method: Tap::Support::Joins::Fork#join

Defined in:
lib/tap/support/joins/fork.rb

#join(source, targets) ⇒ Object 



7
8
9
10
11
12
13
14
 
# File 'lib/tap/support/joins/fork.rb', line 7

def join(source, targets)
  complete(source) do |_result|
    targets.each do |target| 
      yield(_result) if block_given?
      enq(target, _result)
    end
  end
end