93 mtd = getattr(self.remote, name) |
93 mtd = getattr(self.remote, name) |
94 batchablefn = getattr(mtd, 'batchable', None) |
94 batchablefn = getattr(mtd, 'batchable', None) |
95 if batchablefn is not None: |
95 if batchablefn is not None: |
96 batchable = batchablefn(mtd.im_self, *args, **opts) |
96 batchable = batchablefn(mtd.im_self, *args, **opts) |
97 encargsorres, encresref = next(batchable) |
97 encargsorres, encresref = next(batchable) |
98 if encresref: |
98 assert encresref |
99 req.append((name, encargsorres,)) |
99 req.append((name, encargsorres,)) |
100 rsp.append((batchable, encresref, resref,)) |
100 rsp.append((batchable, encresref, resref,)) |
101 else: |
|
102 resref.set(encargsorres) |
|
103 else: |
101 else: |
104 if req: |
102 if req: |
105 self._submitreq(req, rsp) |
103 self._submitreq(req, rsp) |
106 req, rsp = [], [] |
104 req, rsp = [], [] |
107 resref.set(mtd(*args, **opts)) |
105 resref.set(mtd(*args, **opts)) |