Sha256: 518e8b7f4a65fdd10903b99bb7e43c4106a3be6ae3a1e041a8fa7958ff18a53d

Contents?: true

Size: 464 Bytes

Versions: 13

Compression:

Stored size: 464 Bytes

Contents

# frozen_string_literal: true

require_relative './base_processor'
require_relative './filter/enumerable_adapter'
require_relative './filter/active_record_adapter'

class ActiveSet
  class FilterProcessor < BaseProcessor
    queue_adapter ActiveRecordAdapter
    queue_adapter EnumerableAdapter

    def process
      adapters.reduce(@set) do |outer_set, adapter|
        @instructions.process_adapter(set: outer_set, adapter: adapter)
      end
    end
  end
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version Path
activeset-0.5.8 lib/active_set/processors/filter_processor.rb
activeset-0.5.7 lib/active_set/processors/filter_processor.rb
activeset-0.5.6 lib/active_set/processors/filter_processor.rb
activeset-0.5.5 lib/active_set/processors/filter_processor.rb
activeset-0.5.4 lib/active_set/processors/filter_processor.rb
activeset-0.5.3 lib/active_set/processors/filter_processor.rb
activeset-0.5.2 lib/active_set/processors/filter_processor.rb
activeset-0.5.1 lib/active_set/processors/filter_processor.rb
activeset-0.5.0 lib/active_set/processors/filter_processor.rb
activeset-0.4.4 lib/active_set/processors/filter_processor.rb
activeset-0.4.3 lib/active_set/processors/filter_processor.rb
activeset-0.4.2 lib/active_set/processors/filter_processor.rb
activeset-0.4.1 lib/active_set/processors/filter_processor.rb