Contents

module MiniCamel
  module Processor
    class ProcessEach < Each

      def call(exchange)
        additional_data = fetch_additional_data(exchange)

        # The use of map is no coincidence! (will be used as result in TransformEach)
        fetch_collection(exchange).map do |entry|
          process(entry, additional_data)
        end
      end

    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
mini_camel-0.5.8	lib/mini_camel/processor/process_each.rb