(idx: int)
| 148 | started = 0 |
| 149 | |
| 150 | async def worker(idx: int): |
| 151 | nonlocal started |
| 152 | async with sem: |
| 153 | if jitter > 0: |
| 154 | await asyncio.sleep(random.random()*jitter) |
| 155 | res = await socks5_http_get(timeout, phase_name) |
| 156 | results.append(res) |
| 157 | |
| 158 | tasks = [] |
| 159 | for i in range(total): |
no test coverage detected