(self)
| 41 | self.shutdown() |
| 42 | |
| 43 | def running(self): |
| 44 | opts = [ |
| 45 | ctx.options.client_replay, |
| 46 | ctx.options.server_replay, |
| 47 | ctx.options.rfile, |
| 48 | ] |
| 49 | if any(opts) and not ctx.options.keepserving: |
| 50 | asyncio_utils.create_task( |
| 51 | self.watch(), |
| 52 | name="keepserving", |
| 53 | keep_ref=True, |
| 54 | ) |