summaryrefslogtreecommitdiffstats
path: root/Lib/asyncio
diff options
context:
space:
mode:
authorAlex Grönholm <alex.gronholm@nextday.fi>2020-11-26 10:09:12 (GMT)
committerGitHub <noreply@github.com>2020-11-26 10:09:12 (GMT)
commite3ef4d7f653976ac0ccacc4e3fde06bf0e0f139b (patch)
tree2b77b57f3112c2bf168e5bf93066a66efc652ae9 /Lib/asyncio
parentf533cb80cbbb7acdf9ce1978cfba095ce5eeedaa (diff)
downloadcpython-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.py8
-rw-r--r--Lib/asyncio/events.py14
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,