Class: JRubyParallelProcessing::StreamProcessorCallable

Inherits:

ApplicationCallable

• Object
• ApplicationCallable
• JRubyParallelProcessing::StreamProcessorCallable

Includes:

ChunkProcessor

Defined in:

lib/jruby_parallel_processing/stream_processor_callable.rb

Instance Method Summary

• #initialize(queue, logger, process_chunk_block) ⇒ StreamProcessorCallable constructor

  A new instance of StreamProcessorCallable.

Methods included from ChunkProcessor

#process_chunk

Methods inherited from ApplicationCallable

#call

Constructor Details

#initialize(queue, logger, process_chunk_block) ⇒ StreamProcessorCallable

Returns a new instance of StreamProcessorCallable.

# File 'lib/jruby_parallel_processing/stream_processor_callable.rb', line 7

def initialize(queue, logger, process_chunk_block)
  super(&method(:process))
  @queue = queue
  @logger = logger
  @process_chunk_block = process_chunk_block
end