Hand control over to the event loop (e.g. if waiting indefinitely for incoming messages)
(self)
| 487 | return self.conn.state & (Endpoint.LOCAL_CLOSED | Endpoint.REMOTE_CLOSED) |
| 488 | |
| 489 | def run(self) -> None: |
| 490 | """ |
| 491 | Hand control over to the event loop (e.g. if waiting indefinitely for incoming messages) |
| 492 | """ |
| 493 | while self.container.process(): |
| 494 | pass |
| 495 | self.container.stop() |
| 496 | self.container.process() |
| 497 | |
| 498 | def wait( |
| 499 | self, |