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

def process_streaming_response(chunk)
  data = JSON.parse(chunk)
  yield [RecordMessage.new(data: data, emitted_at: Time.now.to_i).to_multiwoven_message] if block_given?
rescue StandardError => e
  handle_exception(e, { context: "HTTP MODEL:PROCESS_STREAMING_RESPONSE:EXCEPTION", type: "error" })
end