class Multiwoven::Integrations::Source::HttpModel::Client

def run_model_stream(connection_config, payload)
  send_streaming_request(
    url: connection_config[:url_host],
    http_method: connection_config[:http_method],
    payload: payload,
    headers: connection_config[:headers],
    config: connection_config[:config]
  ) do |chunk|
    process_streaming_response(chunk) { |message| yield message if block_given? }
  end
rescue StandardError => e
  handle_exception(e, { context: "HTTP MODEL:RUN_STREAM_MODEL:EXCEPTION", type: "error" })
end