'Test ConstantReconnectionPolicy schedule'

def test_schedule(self):

    delay = 2
    max_attempts = 100
    policy = ConstantReconnectionPolicy(delay=delay, max_attempts=max_attempts)
    schedule = list(policy.new_schedule())
    self.assertEqual(len(schedule), max_attempts)
    for (i, delay) in enumerate(schedule):
        self.assertEqual(delay, delay)
