Method: Karafka::Pro::Processing::Collapser#initialize

Defined in:
lib/karafka/pro/processing/collapser.rb

#initialize ⇒ Collapser

When initialized, nothing is collapsed



20
21
22
23
24
 
# File 'lib/karafka/pro/processing/collapser.rb', line 20

def initialize
  @collapsed = false
  @until_offset = -1
  @mutex = Mutex.new
end