Fibers fourth example

fiber_four.rb

require "fiber"

def find_in_batches_with_fiber
  Fiber.new do
    index = 0
    chunk_size = 2
    while batch = query_batch(index, chunk_size)
      break if batch.length == 0
      Fiber.yield batch
      index += 1
    end
  end
end

def complex_operation_in_background_with_fibers(fiber = nil)
  fiber ||= find_in_batches_with_fiber

  if fiber.alive? && (batch = fiber.resume)
    process_batch(batch)
    complex_operation_in_background_with_fibers(fiber)
  end
end

# Execution in the terminal
# >> complex_operation_in_background_with_fibers
# ["Vhils", "AKACORLEONE"]
# ["Pixel Pancho", "+-"]
# ["Kruella D'Enfer", "Tamara Alves"]
# ["Add Fuel", "MAR"]
# ["Eime", "Bordalo II"]
# ["Felipe Pantone", "Ernest Zacharevic"]
# ["Wasted Rita", "Sainer"]