diff options
author | Alex Grönholm <alex.gronholm@nextday.fi> | 2020-11-26 10:09:12 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-11-26 10:09:12 (GMT) |
commit | e3ef4d7f653976ac0ccacc4e3fde06bf0e0f139b (patch) | |
tree | 2b77b57f3112c2bf168e5bf93066a66efc652ae9 /Lib/asyncio | |
parent | f533cb80cbbb7acdf9ce1978cfba095ce5eeedaa (diff) | |
download | cpython-e3ef4d7f653976ac0ccacc4e3fde06bf0e0f139b.zip cpython-e3ef4d7f653976ac0ccacc4e3fde06bf0e0f139b.tar.gz cpython-e3ef4d7f653976ac0ccacc4e3fde06bf0e0f139b.tar.bz2 |
bpo-41332: Added missing connect_accepted_socket() to AbstractEventLoop (GH-21533)
Co-authored-by: Andrew Svetlov <andrew.svetlov@gmail.com>
Co-authored-by: Kyle Stanley <aeros167@gmail.com>
Diffstat (limited to 'Lib/asyncio')
-rw-r--r-- | Lib/asyncio/base_events.py | 8 | ||||
-rw-r--r-- | Lib/asyncio/events.py | 14 |
2 files changed, 14 insertions, 8 deletions
diff --git a/Lib/asyncio/base_events.py b/Lib/asyncio/base_events.py index b2d446a..d71d6f7 100644 --- a/Lib/asyncio/base_events.py +++ b/Lib/asyncio/base_events.py @@ -1525,14 +1525,6 @@ class BaseEventLoop(events.AbstractEventLoop): self, protocol_factory, sock, *, ssl=None, ssl_handshake_timeout=None): - """Handle an accepted connection. - - This is used by servers that accept connections outside of - asyncio but that use asyncio to handle connections. - - This method is a coroutine. When completed, the coroutine - returns a (transport, protocol) pair. - """ if sock.type != socket.SOCK_STREAM: raise ValueError(f'A Stream Socket was expected, got {sock!r}') diff --git a/Lib/asyncio/events.py b/Lib/asyncio/events.py index 0dce87b..1a20f36 100644 --- a/Lib/asyncio/events.py +++ b/Lib/asyncio/events.py @@ -418,6 +418,20 @@ class AbstractEventLoop: """ raise NotImplementedError + async def connect_accepted_socket( + self, protocol_factory, sock, + *, ssl=None, + ssl_handshake_timeout=None): + """Handle an accepted connection. + + This is used by servers that accept connections outside of + asyncio, but use asyncio to handle connections. + + This method is a coroutine. When completed, the coroutine + returns a (transport, protocol) pair. + """ + raise NotImplementedError + async def create_datagram_endpoint(self, protocol_factory, local_addr=None, remote_addr=None, *, family=0, proto=0, flags=0, |