Module: JRubyParallelProcessing::ChunkProcessor

Included in:
DataProcessor, StreamProcessorCallable
Defined in:
lib/jruby_parallel_processing/chunk_processor.rb

Instance Method Summary collapse

Instance Method Details

#process_chunk(chunk, &block) ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/jruby_parallel_processing/chunk_processor.rb', line 5

def process_chunk(chunk, &block)
  chunk.each do |data|
    block.call(data)
  rescue => e
    @logger.error("Error processing data: #{e.message}")
  end
end