connector
This commit is contained in:
parent
da8019ef1f
commit
d7971af08a
@ -278,8 +278,11 @@ class Connector:
|
|||||||
|
|
||||||
async def get_next_block(self):
|
async def get_next_block(self):
|
||||||
if self.active:
|
if self.active:
|
||||||
if not self.get_next_block_mutex.done():
|
while True:
|
||||||
await self.get_next_block_mutex
|
if not self.get_next_block_mutex.done():
|
||||||
|
await self.get_next_block_mutex
|
||||||
|
continue
|
||||||
|
break
|
||||||
try:
|
try:
|
||||||
self.get_next_block_mutex = asyncio.Future()
|
self.get_next_block_mutex = asyncio.Future()
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user