(self, hook: commands.StartHook)
| 125 | logger.log(level=level, msg=f"[replay] {message}") |
| 126 | |
| 127 | async def handle_hook(self, hook: commands.StartHook) -> None: |
| 128 | (data,) = hook.args() |
| 129 | await ctx.master.addons.handle_lifecycle(hook) |
| 130 | if isinstance(data, flow.Flow): |
| 131 | await data.wait_for_resume() |
| 132 | if isinstance(hook, (layers.http.HttpResponseHook, layers.http.HttpErrorHook)): |
| 133 | if self.transports: |
| 134 | # close server connections |
| 135 | for x in self.transports.values(): |
| 136 | if x.handler: |
| 137 | x.handler.cancel() |
| 138 | await asyncio.wait( |
| 139 | [x.handler for x in self.transports.values() if x.handler] |
| 140 | ) |
| 141 | # signal completion |
| 142 | self.done.set() |
| 143 | |
| 144 | |
| 145 | class ClientPlayback: |
nothing calls this directly
no test coverage detected