Sha256: f56f4485ee2cc5defdd9e935dc08552d84fe0a61e8ba28ee4a7b7465a663f40a

Contents?: true

Size: 485 Bytes

Versions: 13

Compression:

Stored size: 485 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!
      ].each do |caught_delegator|
        define_method(caught_delegator) { |*| }
      end
    end
  end
end

Version data entries

13 entries across 13 versions & 1 rubygems

Version Path
karafka-testing-2.1.2 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.1.1 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.1.0 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.11 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.10 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.9 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.8 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.7 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.6 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.5 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.4 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.3 lib/karafka/testing/spec_consumer_client.rb
karafka-testing-2.0.2 lib/karafka/testing/spec_consumer_client.rb