Lines Matching refs:apply_result
151 apply_result = ApplyResult(callback=callback)
152 job = Job(func, args, kwds, apply_result)
154 return apply_result
165 apply_result = ApplyResult(callback=callback)
166 collector = OrderedResultCollector(apply_result, as_iterator=False)
168 apply_result._set_value([])
169 return apply_result
181 apply_result = ApplyResult(callback=callback)
182 collector = OrderedResultCollector(apply_result, as_iterator=True)
184 apply_result._set_value(iter([]))
185 return apply_result
198 apply_result = ApplyResult(callback=callback)
199 collector = UnorderedResultCollector(apply_result)
201 apply_result._set_value(iter([]))
202 return apply_result
256 apply_result = ApplyResult(collector)
257 job = Job(func, (arg,), {}, apply_result)
269 def __init__(self, func, args, kwds, apply_result): argument
278 self._result = apply_result
412 def register_result(self, apply_result): argument
421 def notify_ready(self, apply_result): argument
465 apply_result = self._collector._get_result(self._idx, timeout)
474 assert apply_result.ready()
475 return apply_result.get(0)
497 def register_result(self, apply_result): argument
534 def notify_ready(self, apply_result=None): argument
544 self._collection.append(apply_result)
576 def register_result(self, apply_result): argument
583 self._results.append(apply_result)
599 def notify_ready(self, apply_result): argument