notwa/respodns
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

fix pooler so finisher is optional

Browse source
This commit is contained in:
Connor Olding 2020-09-01 08:22:05 +02:00
parent 3b31919f75
commit 9a3598b599
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
respodns/util.py
View file

@ -64,6 +64,7 @@ def make_pooler(pool_size, finisher=None):
desired_size = 0 if finish else pool_size - 1 desired_size = 0 if finish else pool_size - 1
while len(pending) > desired_size: while len(pending) > desired_size:
done, pending = await wait(pending, return_when=FIRST_COMPLETED) done, pending = await wait(pending, return_when=FIRST_COMPLETED)
if finisher is not None:
finisher(done, pending) finisher(done, pending)
return pooler return pooler