(self, request_id, body)
| 123 | raise ua.UaError("Unsupported message type: {}".format(msg)) |
| 124 | |
| 125 | def _call_callback(self, request_id, body): |
| 126 | with self._lock: |
| 127 | future = self._callbackmap.pop(request_id, None) |
| 128 | if future is None: |
| 129 | raise ua.UaError( |
| 130 | "No future object found for request: {0}, callbacks in list are {1}" |
| 131 | .format(request_id, self._callbackmap.keys()) |
| 132 | ) |
| 133 | future.set_result(body) |
| 134 | |
| 135 | def _cancel_all_callbacks(self): |
| 136 | for request_id, fut in self._callbackmap.items(): |