Class: Karafka::Testing::Minitest::Proxy

Inherits:
Object
  • Object
show all
Defined in:
lib/karafka/testing/minitest/proxy.rb

Overview

Proxy object for a nicer ‘karafka.` API within Minitest None other should be used by the end users

Instance Method Summary collapse

Constructor Details

#initialize(minitest_example) ⇒ Proxy

Returns a new instance of Proxy.

Parameters:

  • minitest_example (Minitest::Test) —

    minitest context



10
11
12
 
# File 'lib/karafka/testing/minitest/proxy.rb', line 10

def initialize(minitest_example)
  @minitest_example = minitest_example
end

Instance Method Details

#consumer_for ⇒ Object

Forwards all arguments to ‘#_karafka_consumer_for`



15
16
17
 
# File 'lib/karafka/testing/minitest/proxy.rb', line 15

def consumer_for(*)
  @minitest_example._karafka_consumer_for(*)
end

#consumer_messages ⇒ Array<Karafka::Messages::Message>

Returns array of messages that will be used to construct the final consumer messages batch.

Returns:

  • (Array<Karafka::Messages::Message>) —

    array of messages that will be used to construct the final consumer messages batch



36
37
38
 
# File 'lib/karafka/testing/minitest/proxy.rb', line 36

def consumer_messages
  @minitest_example._karafka_consumer_messages
end

#produce ⇒ Object

Forwards all arguments to ‘#_karafka_produce`



20
21
22
 
# File 'lib/karafka/testing/minitest/proxy.rb', line 20

def produce(*)
  @minitest_example._karafka_produce(*)
end

#produce_to ⇒ Object

Forwards all arguments to ‘#_karafka_produce_to`



25
26
27
 
# File 'lib/karafka/testing/minitest/proxy.rb', line 25

def produce_to(*)
  @minitest_example._karafka_produce_to(*)
end

#produced_messages ⇒ Array<Hash>

Returns messages produced via ‘Karafka#producer`.

Returns:

  • (Array<Hash>) —

    messages produced via ‘Karafka#producer`



30
31
32
 
# File 'lib/karafka/testing/minitest/proxy.rb', line 30

def produced_messages
  @minitest_example._karafka_produced_messages
end