Method: LazierData::Processor#initialize

Defined in:
lib/lazier_data/processor.rb

#initialize(upstream, batch_size, path, &block) ⇒ Processor

Returns a new instance of Processor.



18
19
20
21
22
23
24
 
# File 'lib/lazier_data/processor.rb', line 18

def initialize(upstream, batch_size, path, &block)
  @upstream = upstream
  @downstream = downstream
  @batch_size = batch_size
  @path = path
  @block = block
end