Loading DHParser/server.py +2 −0 Original line number Diff line number Diff line Loading @@ -151,6 +151,7 @@ def asyncio_run(coroutine: Coroutine, loop=None) -> Any: result = myloop.run_until_complete(coroutine) if loop is None: asyncio.set_event_loop(None) myloop.run_until_complete(loop.shutdown_asyncgens()) myloop.close() return result Loading Loading @@ -415,6 +416,7 @@ class Server: finally: if loop is None: asyncio.set_event_loop(None) self.loop.run_until_complete(loop.shutdown_asyncgens()) self.loop.close() self.server.close() asyncio_run(self.server.wait_closed()) Loading test/test_server.py +0 −2 Original line number Diff line number Diff line Loading @@ -23,10 +23,8 @@ limitations under the License. import asyncio import json import os from multiprocessing import Process import sys import time from typing import Tuple sys.path.extend(['../', './']) Loading Loading
DHParser/server.py +2 −0 Original line number Diff line number Diff line Loading @@ -151,6 +151,7 @@ def asyncio_run(coroutine: Coroutine, loop=None) -> Any: result = myloop.run_until_complete(coroutine) if loop is None: asyncio.set_event_loop(None) myloop.run_until_complete(loop.shutdown_asyncgens()) myloop.close() return result Loading Loading @@ -415,6 +416,7 @@ class Server: finally: if loop is None: asyncio.set_event_loop(None) self.loop.run_until_complete(loop.shutdown_asyncgens()) self.loop.close() self.server.close() asyncio_run(self.server.wait_closed()) Loading
test/test_server.py +0 −2 Original line number Diff line number Diff line Loading @@ -23,10 +23,8 @@ limitations under the License. import asyncio import json import os from multiprocessing import Process import sys import time from typing import Tuple sys.path.extend(['../', './']) Loading