Module: Rimless::RSpec::Matchers

Defined in:
lib/rimless/rspec/matchers.rb

Overview

A set of Rimless/RSpec matchers.

Defined Under Namespace

Classes: HaveSentKafkaMessage

Instance Method Summary collapse

Instance Method Details

#have_sent_kafka_message(schema = nil) ⇒ Object Also known as: sent_kafka_message

Check for messages which were sent to Apache Kafka by the given block.

rubocop:disable Naming/PredicateName because its a RSpec matcher

Parameters:

  • schema (String, Symbol, nil) (defaults to: nil)

    the Apache Avro schema to check



279
280
281
# File 'lib/rimless/rspec/matchers.rb', line 279

def have_sent_kafka_message(schema = nil)
  HaveSentKafkaMessage.new(schema)
end