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!
      ].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

1 entries across 1 versions & 1 rubygems

Version	Path
karafka-testing-2.1.5	lib/karafka/testing/spec_consumer_client.rb