Sha256: 910daab5af0a2c53b58ef62dcdefe1e72ed019b285e4276b828c16ee03a6e27a
Contents?: true
Size: 665 Bytes
Versions: 16
Compression:
Stored size: 665 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Testing
# A spec client that takes over client delegated methods from the consumers
# For specs we do not mark anything as consumed, nor do we really send heartbeats.
# Those things are tested in the framework itself
class SpecConsumerClient
%i[
mark_as_consumed
mark_as_consumed!
commit_offsets
commit_offsets!
seek
].each do |caught_delegator|
define_method(caught_delegator) { |*| true }
end
# @return [Boolean] assignments are never lost for specs
def assignment_lost?
false
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems