class Messages
@private
Public Class Methods
new()
click to toggle source
# File lib/sidekiq/trackable_batch/messages.rb, line 5 def initialize @messages = [] end
Public Instance Methods
<<(msg)
click to toggle source
# File lib/sidekiq/trackable_batch/messages.rb, line 9 def <<(msg) @messages << msg end
clear()
click to toggle source
# File lib/sidekiq/trackable_batch/messages.rb, line 25 def clear @messages.clear end
empty?()
click to toggle source
# File lib/sidekiq/trackable_batch/messages.rb, line 17 def empty? @messages.empty? end
max_sum()
click to toggle source
# File lib/sidekiq/trackable_batch/messages.rb, line 13 def max_sum @messages.reduce(0) { |memo, msg| memo + msg['max'] } end
to_json()
click to toggle source
# File lib/sidekiq/trackable_batch/messages.rb, line 21 def to_json @messages.map(&:to_json) end