Module: Replay::EventExaminer

Included in:
TestEventStream
Defined in:
lib/replay/test.rb

Instance Method Summary collapse

Instance Method Details

#apply(events, raise_unhandled = true) ⇒ Object 



20
21
22
23
24
25
26
27
 
# File 'lib/replay/test.rb', line 20

def apply(events, raise_unhandled = true)
  return apply([events], raise_unhandled) unless events.is_a?(Array)
  retval = super(events, raise_unhandled)
  events.each do |event|
    self.events << event
  end
  return retval
end

#events ⇒ Object 



4
5
6
 
# File 'lib/replay/test.rb', line 4

def events
  @_events ||= []
end

#has_subscriber?(subscriber) ⇒ Boolean

Returns:

  • (Boolean) 


29
30
31
 
# File 'lib/replay/test.rb', line 29

def has_subscriber?(subscriber)
  @subscription_manager.has_subscriber?(subscriber)
end

#published?(event, fuzzy = false) ⇒ Boolean

Returns:

  • (Boolean) 


8
9
10
11
12
13
14
 
# File 'lib/replay/test.rb', line 8

def published?(event, fuzzy=false)
  if fuzzy
    !(events.detect{|e| event.kind_of_matches?(e) }.nil?)
  else
    events.detect{|e| event.is_a?(Class) ? e.class == event : e == event}
  end
end

#similar_events(event) ⇒ Object 



16
17
18
 
# File 'lib/replay/test.rb', line 16

def similar_events(event)
  events.select{|e| e.class == event.class}
end