Chia-Network/chia-blockchain
1
0
Fork 0
mirror of https://github.com/Chia-Network/chia-blockchain.git synced 2024-07-14 22:20:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

introducer just manage (#16757)

Browse Source
This commit is contained in:
Kyle Altendorf 2023-11-21 18:14:10 -05:00 committed by GitHub
parent 576ec7c08c
commit 6d480b8256
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
chia/introducer/introducer.py
View File

@ -38,23 +38,13 @@ class Introducer:
@contextlib.asynccontextmanager
async def manage(self) -> AsyncIterator[None]:
await self._start()
self._vetting_task = asyncio.create_task(self._vetting_loop())
try:
yield
finally:
self._close()
await self._await_closed()
async def _start(self):
self._vetting_task = asyncio.create_task(self._vetting_loop())
def _close(self):
self._shut_down = True
self._vetting_task.cancel()
async def _await_closed(self):
pass
# await self._vetting_task
self._shut_down = True
self._vetting_task.cancel()
# await self._vetting_task
async def on_connect(self, peer: WSChiaConnection) -> None:
pass