class Anthropic::Internal::Stream

end
puts(event)
stream.each do |event|
@example
@generic Elem

def iterator

Returns:
  • (Enumerable>) -

Other tags:
    Api: - private 
def iterator
cop:disable Metrics/BlockLength
cop:disable Layout/LineLength
cop:disable Lint/DuplicateBranch
tor ||= Anthropic::Internal::Util.chain_fused(@stream) do |y|
eam.each do |msg|
se msg
 {event: "completion", data: String => data}
decoded = JSON.parse(data, symbolize_names: true)
unwrapped = Anthropic::Internal::Util.dig(decoded, @unwrap)
y << Anthropic::Internal::Type::Converter.coerce(@model, unwrapped)
 {
event: "message_start" | "message_delta" | "message_stop" | "content_block_start" | "content_block_delta" | "content_block_stop",
data: String => data
decoded = JSON.parse(data, symbolize_names: true)
unwrapped = Anthropic::Internal::Util.dig(decoded, @unwrap)
y << Anthropic::Internal::Type::Converter.coerce(@model, unwrapped)
 {event: "ping"}
next
 {event: "error", data: String => data}
decoded = Kernel.then do
  JSON.parse(data, symbolize_names: true)
rescue JSON::ParserError
  data
end
Anthropic::Errors::APIStatusError.for(
  url: @url,
  status: @status,
  body: decoded,
  request: nil,
  response: @response
)
se
d
cop:enable Lint/DuplicateBranch
cop:enable Layout/LineLength
cop:enable Metrics/BlockLength