class Anthropic::Helpers::Streaming::MessageStream

def initialize(raw_stream:)
  # The underlying Server-Sent Event stream from the Anthropic API.
  @raw_stream = raw_stream
  # Accumulated message state that builds up as events are processed.
  @accumated_message_snapshot = nil
  # Lazy enumerable that transforms raw events into consumable events.
  @iterator = iterator
end