def _wait()

in gym3/asynchronous.py [0:0]

• 5 lines of code
• 4 McCabe index (conditional complexity)

    def _wait(self):
        if len(self._futures) > 0:
            # wait for all pending act calls to complete
            for future in self._futures:
                # this will re-raise any exceptions from the worker thread
                future.result()
            self._futures = []