Class: A2A::Streaming::Subscription

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

Defined Under Namespace

Classes: ChunkedReader

Instance Method Summary collapse

Constructor Details

#initialize(io) ⇒ Subscription

Returns a new instance of Subscription.



8
9
10
 
# File 'lib/a2a/streaming/subscription.rb', line 8

def initialize(io)
  @io = io
end

Instance Method Details

#each(&block) ⇒ Object 



12
13
14
15
16
17
18
19
 
# File 'lib/a2a/streaming/subscription.rb', line 12

def each(&block)
  return enum_for(:each) unless block

  SseParser.each(reader) do |event|
    yield event
    break if terminal?(event)
  end
end