Class: A2A::Streaming::Subscription::ChunkedReader

Inherits:
Object
  • Object
show all
Defined in:
lib/a2a/streaming/subscription.rb

Overview

Wraps Net::HTTPResponse so SseParser can call each_line on it.

Instance Method Summary collapse

Constructor Details

#initialize(response) ⇒ ChunkedReader

Returns a new instance of ChunkedReader.



44
45
46
 
# File 'lib/a2a/streaming/subscription.rb', line 44

def initialize(response)
  @response = response
end

Instance Method Details

#each_line(&block) ⇒ Object 



48
49
50
51
52
 
# File 'lib/a2a/streaming/subscription.rb', line 48

def each_line(&block)
  @response.read_body do |chunk|
    chunk.each_line(&block)
  end
end