Class: Karafka::Testing::RSpec::Proxy

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

Overview

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

Instance Method Summary collapse

Constructor Details

#initialize(rspec_example) ⇒ Proxy

Returns a new instance of Proxy.

Parameters:

  • rspec_example (RSpec::ExampleGroups) —

    rspec context



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

def initialize(rspec_example)
  @rspec_example = rspec_example
end

Instance Method Details

#consumer_for ⇒ Object

Forwards all arguments to ‘#_karafka_consumer_for`



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

def consumer_for(*)
  @rspec_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/rspec/proxy.rb', line 36

def consumer_messages
  @rspec_example._karafka_consumer_messages
end

#produce ⇒ Object

Forwards all arguments to ‘#_karafka_produce`



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

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

#produce_to ⇒ Object

Forwards all arguments to ‘#_karafka_produce_to`



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

def produce_to(*)
  @rspec_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/rspec/proxy.rb', line 30

def produced_messages
  @rspec_example._karafka_produced_messages
end