Class: Spikard::Testing::SseStream

Inherits:
Object
  • Object
show all
Defined in:
lib/spikard/testing.rb

Overview

SSE stream wrapper

Instance Method Summary collapse

Constructor Details

#initialize(native_sse) ⇒ SseStream

Returns a new instance of SseStream.



141
142
143
 
# File 'lib/spikard/testing.rb', line 141

def initialize(native_sse)
  @native_sse = native_sse
end

Instance Method Details

#body ⇒ Object 



145
146
147
 
# File 'lib/spikard/testing.rb', line 145

def body
  @native_sse.body
end

#events ⇒ Object 



149
150
151
 
# File 'lib/spikard/testing.rb', line 149

def events
  parsed_chunks.map { |chunk| InlineSseEvent.new(chunk) }
end

#events_as_json ⇒ Object 



153
154
155
156
157
158
159
 
# File 'lib/spikard/testing.rb', line 153

def events_as_json
  parsed_chunks.filter_map do |chunk|
    JSON.parse(chunk)
  rescue JSON::ParserError
    nil
  end
end