class Anthropic::Helpers::Streaming::MessageStream

def iterator

Returns:
  • (Enumerable>) -

Other tags:
    Api: - private 
def iterator
tor ||= Anthropic::Internal::Util.chain_fused(@stream) do |y|
_stream.each do |raw_event|
ccumated_message_snapshot = accumulate_event(
event: raw_event,
current_snapshot: @accumated_message_snapshot
ents_to_yield = build_events(event: raw_event, message_snapshot: @accumated_message_snapshot)
ents_to_yield.each(&y)