Always explicitly create event loop

README.md

@@ -34,7 +34,7 @@ async def amain():
         print(await viewer_control_api.get("Global", "StatsPilotFile"), file=sys.stderr)
 
 
-loop = asyncio.get_event_loop_policy().get_event_loop()
+loop = asyncio.new_event_loop()
 loop.run_until_complete(amain())
 ```
 

examples/complex_leap_script.py

@@ -114,7 +114,7 @@ async def client_connected(client: LEAPClient):
 
 def receiver_main():
     logging.basicConfig(level=logging.INFO)
-    loop = asyncio.get_event_loop_policy().get_event_loop()
+    loop = asyncio.new_event_loop()
 
     args = sys.argv[1:]
     if args and args[0] == "--tcp":

examples/simple_leap_script.py

@@ -15,7 +15,7 @@ async def amain():
 
 
 def main():
-    loop = asyncio.get_event_loop_policy().get_event_loop()
+    loop = asyncio.new_event_loop()
     loop.run_until_complete(amain())
 
 

src/outleap/scripts/agent.py

@@ -48,7 +48,7 @@ async def amain():
 
 
 def agent_main():
-    loop = asyncio.get_event_loop_policy().get_event_loop()
+    loop = asyncio.new_event_loop()
     loop.run_until_complete(amain())
 
 

src/outleap/scripts/repl.py

@@ -50,7 +50,7 @@ async def client_connected(self, client: outleap.LEAPClient):
 
 def repl_main():
     logging.basicConfig()
-    loop = asyncio.get_event_loop_policy().get_event_loop()
+    loop = asyncio.new_event_loop()
     repl_server = REPLServer()
     server = outleap.LEAPBridgeServer(repl_server.client_connected)
     coro = asyncio.start_server(server.handle_connection, "127.0.0.1", 9063)

src/outleap/utils.py

@@ -82,7 +82,7 @@ async def _make_hacky_threaded_stdio_rw() -> Tuple[asyncio.StreamReader, asyncio
     #
     # TODO: Currently we also use this if we're reading from a non-pipe file descriptor on POSIX
     #  platforms, but that's probably unnecessary.
-    loop = asyncio.get_event_loop_policy().get_event_loop()
+    loop = asyncio.get_event_loop()
     reader = asyncio.StreamReader(limit=_READER_BUFFER_LIMIT)
     protocol = HackySTDIOProtocol()
     transport = HackySTDIOTransport()
@@ -157,7 +157,7 @@ async def connect_stdin_stdout() -> Tuple[asyncio.StreamReader, asyncio.StreamWr
             need_stdin_hack = True
     if need_stdin_hack:
         return await _make_hacky_threaded_stdio_rw()
-    loop = asyncio.get_event_loop_policy().get_event_loop()
+    loop = asyncio.get_event_loop()
     reader = asyncio.StreamReader(limit=_READER_BUFFER_LIMIT)
     protocol = asyncio.StreamReaderProtocol(reader)
     await loop.connect_read_pipe(lambda: protocol, sys.stdin)

tests/test_stdio.py

@@ -33,7 +33,7 @@ async def amain():
         # Ask for a config value and print it in the viewer logs
         await viewer_control_api.get("Global", "StatsPilotFile")
 
-loop = asyncio.get_event_loop_policy().get_event_loop()
+loop = asyncio.new_event_loop()
 loop.run_until_complete(amain())
 """