Approximate number of flows queued for replay.
(self)
| 239 | |
| 240 | @command.command("replay.client.count") |
| 241 | def count(self) -> int: |
| 242 | """ |
| 243 | Approximate number of flows queued for replay. |
| 244 | """ |
| 245 | return self.queue.qsize() + int(bool(self.inflight)) |
| 246 | |
| 247 | @command.command("replay.client.stop") |
| 248 | def stop_replay(self) -> None: |
no outgoing calls