Lines Matching refs:timeout
337 def get(self, timeout=None): argument
344 if not self.wait(timeout):
345 raise TimeoutError("Result not available within %fs" % timeout)
350 def wait(self, timeout=None): argument
353 self._event.wait(timeout)
430 def _get_result(self, idx, timeout=None): argument
460 def next(self, timeout=None): argument
465 apply_result = self._collector._get_result(self._idx, timeout)
506 def _get_result(self, idx, timeout=None): argument
525 self._cond.wait(timeout=timeout)
586 def _get_result(self, idx, timeout=None): argument
596 res.wait(timeout)