Class: Replay::TestEventStream

Inherits:
Object
  • Object
show all
Defined in:
lib/replay/test/test_event_stream.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ TestEventStream

Returns a new instance of TestEventStream.



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

def initialize
  @events = []
end

Instance Method Details

#publish(stream_id, event) ⇒ Object 



7
8
9
 
# File 'lib/replay/test/test_event_stream.rb', line 7

def publish(stream_id, event)
  @events << {stream: stream_id, event: event}
end

#published?(stream_id, event) ⇒ Boolean

Returns:

  • (Boolean) 


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

def published?(stream_id, event)
  @events.detect{|e| e == {stream: stream_id, event: event}}
end

#published_event?(event) ⇒ Boolean

Returns:

  • (Boolean) 


11
12
13
 
# File 'lib/replay/test/test_event_stream.rb', line 11

def published_event?(event)
  @events.detect{|e| e[:event]==event}
end