Close the connections and network event loop.
(self, *, timeout)
| 751 | self.network_event_loop.run_forever() |
| 752 | |
| 753 | def close(self, *, timeout): |
| 754 | """Close the connections and network event loop.""" |
| 755 | self.network_event_loop.call_soon_threadsafe(self.network_event_loop.stop) |
| 756 | wait_until_helper_internal(lambda: not self.network_event_loop.is_running(), timeout=timeout) |
| 757 | self.network_event_loop.close() |
| 758 | self.join(timeout) |
| 759 | # Safe to remove event loop. |
| 760 | NetworkThread.network_event_loop = None |
| 761 | |
| 762 | @classmethod |
| 763 | def listen(cls, p2p, callback, port=None, addr=None, idx=1): |