equal
deleted
inserted
replaced
110 # future). |
110 # future). |
111 results = [] |
111 results = [] |
112 |
112 |
113 for command, args, opts, finalfuture in self.calls: |
113 for command, args, opts, finalfuture in self.calls: |
114 mtd = getattr(self._remote, command) |
114 mtd = getattr(self._remote, command) |
115 batchable = mtd.batchable(mtd.im_self, *args, **opts) |
115 batchable = mtd.batchable(mtd.__self__, *args, **opts) |
116 |
116 |
117 commandargs, fremote = next(batchable) |
117 commandargs, fremote = next(batchable) |
118 assert fremote |
118 assert fremote |
119 requests.append((command, commandargs)) |
119 requests.append((command, commandargs)) |
120 results.append((command, finalfuture, batchable, fremote)) |
120 results.append((command, finalfuture, batchable, fremote)) |