q
Size: a a a
q
s
G
t
G
s
q
q
G
t
q
q
G
t
s
q
async for value in receive_from_thread:
if value:
if value.response is ResponseType.MSGNOTFOUND:
n = default_n
await sender.send(value, retry=True)
else:
n -= 1
print(n)
if n == 0:
sender.done()
t
q
G
t