process_events_generator

in lib/facebook_ads/ad_objects/server_side/batch_processor.rb [56:71]

• 15 lines of code
• 6 McCabe index (conditional complexity)

    def process_events_generator(event_request_async_to_clone, events)
      index = 0
      Enumerator.new do |generator|
        while index < events.size do
          batch = []
          while index < events.size && batch.size < concurrent_requests do
            event_request_async = event_request_async_to_clone.clone_without_events
            event_request_async.events = events[index, batch_size]
            batch << event_request_async
            index += batch_size
          end
          generator.yield *[batch.map(&:execute)]
        end
      end
    end