def __init__(self, _time_fn=time.time, _random_fn=random.random):
    object.__init__(self)

    self._timeouts = iter(self._TIMEOUT_PER_ATTEMPT)
    self._time_fn = _time_fn
    self._random_fn = _random_fn
Blocking convenience API to parse an entire stream.
dataset/ETHPy150Open ganeti/ganeti/lib/mcpu.py/LockAttemptTimeoutStrategy.__init__--crossover with--dataset/ETHPy150Open byt3bl33d3r/pth-toolkit/lib/python2.7/site-packages/samba/external/subunit/__init__.py/TestProtocolServer.readFrom