(self, grpc_future)
| 71 | self._completion_event = completion_event |
| 72 | |
| 73 | def _set_active_future(self, grpc_future): |
| 74 | if grpc_future is None: |
| 75 | raise RuntimeError( |
| 76 | "_set_active_future invoked with grpc_future=None." |
| 77 | ) |
| 78 | with self._active_grpc_future_lock: |
| 79 | self._active_grpc_future = grpc_future |
| 80 | |
| 81 | def result(self, timeout): |
| 82 | """Analogous to `grpc.Future.result`. Returns the value or exception. |