manager.py 文件源码

def execute_next_for_async(self, request, types, process_object, *args, **kwargs):
        midd = self._call_mapper.get(types, None)

        if midd:
            while 1:
                method = self._get_func(request, midd[0], midd[1])

                if method and callable(method):
                    clear = partial(self.clear_all, request)
                    result = method(process_object, clear, *args, **kwargs)
                    if is_future(result):
                        result = yield result
                    if result:
                        break
                else:
                    break