class EventMachine::Synchrony::Multi

def check_progress(fiber)
  if finished?
    succeed
    # continue processing
    fiber.resume(self) if fiber.alive? && fiber != Fiber.current
  end
end