|
@ -83,8 +83,7 @@ class ChunkRequest: |
|
|
future = self.loop.create_future() |
|
|
future = self.loop.create_future() |
|
|
self.waiters.append(future) |
|
|
self.waiters.append(future) |
|
|
try: |
|
|
try: |
|
|
await future |
|
|
return await future |
|
|
return True |
|
|
|
|
|
finally: |
|
|
finally: |
|
|
self.waiters.remove(future) |
|
|
self.waiters.remove(future) |
|
|
|
|
|
|
|
|