8000 bpo-32418: Postfix, raise NotImplementdError and close resources in t… · python/cpython@ffcb4c0 · GitHub
[go: up one dir, main page]

Skip to content

Commit ffcb4c0

Browse files
authored
bpo-32418: Postfix, raise NotImplementdError and close resources in tests (#5052)
1 parent 1634fc2 commit ffcb4c0

File tree

2 files changed

+22
-5
lines changed

2 files changed

+22
-5
lines changed

Lib/asyncio/events.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -149,15 +149,15 @@ class AbstractServer:
149149

150150
def close(self):
151151
"""Stop serving. This leaves existing connections open."""
152-
return NotImplemented
152+
raise NotImplementedError
153153

154154
async def wait_closed(self):
155155
"""Coroutine to wait until service is closed."""
156-
return NotImplemented
156+
raise NotImplementedError
157157

158158
def get_loop(self):
159159
""" Get the event loop the Server object is attached to."""
160-
return NotImplemented
160+
raise NotImplementedError
161161

162162

163163
class AbstractEventLoop:

Lib/test/test_asyncio/test_events.py

Lines changed: 19 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2826,19 +2826,36 @@ class TestCGetEventLoop(GetEventLoopTestsMixin, unittest.TestCase):
28262826
get_running_loop_impl = events._c_get_running_loop
28272827
get_event_loop_impl = events._c_get_event_loop
28282828

2829+
28292830
class TestServer(unittest.TestCase):
28302831

28312832
def test_get_loop(self):
28322833
loop = asyncio.new_event_loop()
2834+
self.addCleanup(loop.close)
28332835
proto = MyProto(loop)
28342836
server = loop.run_until_complete(loop.create_server(lambda: proto, '0.0.0.0', 0))
28352837
self.assertEqual(server.get_loop(), loop)
2836-
loop.close()
2838+
server.close()
2839+
loop.run_until_complete(server.wait_closed())
2840+
28372841

28382842
class TestAbstractServer(unittest.TestCase):
28392843

2844+
def test_close(self):
2845+
with self.assertRaises(NotImplementedError):
2846+
events.AbstractServer().close()
2847+
2848+
def test_wait_closed(self):
2849+
loop = asyncio.new_event_loop()
2850+
self.addCleanup(loop.close)
2851+
2852+
with self.assertRaises(NotImplementedError):
2853+
loop.run_until_complete(events.AbstractServer().wait_closed())
2854+
28402855
def test_get_loop(self):
2841-
self.assertEqual(events.AbstractServer().get_loop(), NotImplemented)
2856+
with self.assertRaises(NotImplementedError):
2857+
events.AbstractServer().get_loop()
2858+
28422859

28432860
if __name__ == '__main__':
28442861
unittest.main()

0 commit comments

Comments
 (0)
0