@@ -94,7 +94,7 @@ async def server_auto_close(fut, timeout):
94
94
"""Server run based on run_until_complete. It will block forever with handle
95
95
function because it is a while True loop without break. Use this method to close
96
96
server automatically."""
97
- loop = asyncio .get_event_loop ()
97
+ loop = asyncio .get_running_loop ()
98
98
task = asyncio .ensure_future (fut , loop = loop )
99
99
await asyncio .sleep (timeout )
100
100
task .cancel ()
@@ -105,7 +105,8 @@ def test_stateless_server(server):
105
105
"""Create a UDP Server can register instance based on name from message of client.
106
106
Clients can communicate to other client by name through server"""
107
107
108
- loop = asyncio .get_event_loop ()
108
+ loop = asyncio .new_event_loop ()
109
+ asyncio .set_event_loop (loop )
109
110
server .handle = partial (server_auto_close , fut = server .handle (), timeout = 1.0 )
110
111
111
112
client1 = Client (name = "client1" )
@@ -132,7 +133,8 @@ async def check_client2_behavior():
132
133
133
134
def test_server_delete_instance (server ):
134
135
"""The max_applications of Server is 10. After 20 times register, application number should be 10."""
135
- loop = asyncio .get_event_loop ()
136
+ loop = asyncio .new_event_loop ()
137
+ asyncio .set_event_loop (loop )
136
138
server .handle = partial (server_auto_close , fut = server .handle (), timeout = 1.0 )
137
139
138
140
client1 = Client (name = "client1" )
0 commit comments