class TrRMIte::Consumers::Progress

Public Class Methods

new(topic, registry_uri) click to toggle source
Calls superclass method TrRMIte::Consumer::new
# File lib/TrRMIte/consumers/progress.rb, line 7
def initialize(topic, registry_uri)
  super('PROGRESS_CONSUMER', topic, registry_uri)

  @processed_event_count = 0
  @max_event_count = ENV['MAX_EVENT_COUNT'].to_i
end

Private Instance Methods

process(event) click to toggle source
# File lib/TrRMIte/consumers/progress.rb, line 16
def process event
  @progress_bar ||= if @max_event_count.zero?
                      ProgressBar.create(
                        total: nil,
                        format: 'Count: %c |%B| %a'
                      )
                    else
                      ProgressBar.create(
                        total: @max_event_count,
                        format: 'Count: %c/%C(%p%%) |%B| %a %e'
                      )
                    end

  @progress_bar.increment

  @stop_processing = (@processed_event_count += 1) == @max_event_count
end