Class: Streamingly::Reducer

Inherits:
Object
  • Object
show all
Defined in:
lib/streamingly/reducer.rb

Instance Method Summary collapse

Constructor Details

#initialize(accumulator_class, accumulator_options = nil) ⇒ Reducer

Returns a new instance of Reducer.



4
5
6
7
8
 
# File 'lib/streamingly/reducer.rb', line 4

def initialize(accumulator_class, accumulator_options = nil)
  @accumulator_class = accumulator_class
  @accumulator_options = accumulator_options
  @error_callback_defined = @accumulator_class.method_defined?(:on_error)
end

Instance Method Details

#reduce_over(enumerator) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/streamingly/reducer.rb', line 10

def reduce_over(enumerator)
  enumerator.each do |line|
    reduce(line.strip).each do |out|
      yield out
    end
  end

  flush.each do |out|
    yield out
  end

end