class RubyEventStore::RSpec::CrudeFailureMessageFormatter::HavePublished

def failure_message(expected, events, stream_name)
  stream_expectation = " in stream #{stream_name}" unless stream_name.nil?
  "expected #{expected.events} to be published#{stream_expectation}, diff:" +
    differ.diff(expected.events.to_s + "\n", events)
end

def failure_message_when_negated(expected, events, stream_name)
  stream_expectation = " in stream #{stream_name}" unless stream_name.nil?
  "expected #{expected.events} not to be published#{stream_expectation}, diff:" +
    differ.diff(expected.events.to_s + "\n", events)
end

def initialize(differ)
  @differ = differ
end