Lines Matching defs:callback
328 # already finished and its callback is waiting in the queue,
757 def _register(self, ov, obj, callback):
762 # the value returned by callback().
772 value = callback(None, None, ov)
786 self._cache[ov.address] = (f, ov, obj, callback)
824 f, ov, obj, callback = self._cache.pop(address)
842 # Don't call the callback if _register() already read the result or
846 value = callback(transferred, key, ov)
873 for fut, ov, obj, callback in list(self._cache.values()):
925 def callback(f):
930 f.add_done_callback(callback)