Contents

module Tap
  module Support
    module Joins
      
      # A Switch join allows a block to determine which output from an array
      # of outputs will receive the results of the input.
      class Switch < Join
        def join(inputs, outputs)
          inputs.each do |input|
            input.on_complete do |_result| 
              if index = yield(_result)        
                unless output = outputs[index] 
                  raise "no switch target for index: #{index}"
                end

                enq(output, _result)
              else
                input.app.aggregator.store(_result)
              end
            end
          end
        end
      end
      
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
tap-0.12.4	lib/tap/support/joins/switch.rb
tap-0.12.2	lib/tap/support/joins/switch.rb
tap-0.12.0	lib/tap/support/joins/switch.rb
tap-0.12.1	lib/tap/support/joins/switch.rb
tap-0.12.3	lib/tap/support/joins/switch.rb