Close the connections and network event loop.
(self, timeout=10)
| 589 | self.network_event_loop.run_forever() |
| 590 | |
| 591 | def close(self, timeout=10): |
| 592 | """Close the connections and network event loop.""" |
| 593 | self.network_event_loop.call_soon_threadsafe(self.network_event_loop.stop) |
| 594 | wait_until_helper(lambda: not self.network_event_loop.is_running(), timeout=timeout) |
| 595 | self.network_event_loop.close() |
| 596 | self.join(timeout) |
| 597 | # Safe to remove event loop. |
| 598 | NetworkThread.network_event_loop = None |
| 599 | |
| 600 | @classmethod |
| 601 | def listen(cls, p2p, callback, port=None, addr=None, idx=1): |