(self, gen: int, service_id: Optional[ObjectId])
| 920 | await self._reset(close=True) |
| 921 | |
| 922 | def stale_generation(self, gen: int, service_id: Optional[ObjectId]) -> bool: |
| 923 | return self.gen.stale(gen, service_id) |
| 924 | |
| 925 | async def remove_stale_sockets(self, reference_generation: int) -> None: |
| 926 | """Removes stale sockets then adds new ones if pool is too small and |
no test coverage detected