module RubyLLM::Streaming

def handle_sse(chunk, parser, env, &block)
  parser.feed(chunk) do |type, data|
    case type.to_sym
    when :error
      handle_error_event(data, env)
    else
      yield handle_data(data, &block) unless data == '[DONE]'
    end
  end
end