module Phobos::BatchHandler

Public Class Methods

included(base) click to toggle source
# File lib/phobos/batch_handler.rb, line 5
def self.included(base)
  base.extend(ClassMethods)
end

Public Instance Methods

around_consume_batch(payloads, metadata) { |payloads, metadata| ... } click to toggle source
# File lib/phobos/batch_handler.rb, line 13
def around_consume_batch(payloads, metadata)
  yield payloads, metadata
end
consume_batch(_payloads, _metadata) click to toggle source
# File lib/phobos/batch_handler.rb, line 9
def consume_batch(_payloads, _metadata)
  raise NotImplementedError
end