class Multiwoven::Integrations::Core::SourceConnector

def send_streaming_request(options = {})
  Multiwoven::Integrations::Core::StreamingHttpClient.request(
    options[:url],
    options[:http_method],
    payload: options[:payload],
    headers: options[:headers],
    config: options[:config]
  ) do |chunk|
    yield chunk if block_given? # Pass each chunk for processing (streaming response)
  end
end