summaryrefslogtreecommitdiff
path: root/Lib/asyncio
diff options
context:
space:
mode:
Diffstat (limited to 'Lib/asyncio')
-rw-r--r--Lib/asyncio/base_events.py4
-rw-r--r--Lib/asyncio/coroutines.py12
-rw-r--r--Lib/asyncio/selector_events.py7
-rw-r--r--Lib/asyncio/tasks.py2
-rw-r--r--Lib/asyncio/unix_events.py3
-rw-r--r--Lib/asyncio/windows_events.py3
-rw-r--r--Lib/asyncio/windows_utils.py7
7 files changed, 23 insertions, 15 deletions
diff --git a/Lib/asyncio/base_events.py b/Lib/asyncio/base_events.py
index ac885a8e9a..35c8d742c1 100644
--- a/Lib/asyncio/base_events.py
+++ b/Lib/asyncio/base_events.py
@@ -201,8 +201,8 @@ class BaseEventLoop(events.AbstractEventLoop):
"""Create socket transport."""
raise NotImplementedError
- def _make_ssl_transport(self, rawsock, protocol, sslcontext, waiter=None, *,
- server_side=False, server_hostname=None,
+ def _make_ssl_transport(self, rawsock, protocol, sslcontext, waiter=None,
+ *, server_side=False, server_hostname=None,
extra=None, server=None):
"""Create SSL transport."""
raise NotImplementedError
diff --git a/Lib/asyncio/coroutines.py b/Lib/asyncio/coroutines.py
index c28de95a46..a1b28751f7 100644
--- a/Lib/asyncio/coroutines.py
+++ b/Lib/asyncio/coroutines.py
@@ -182,14 +182,18 @@ def _format_coroutine(coro):
and not inspect.isgeneratorfunction(coro.func)):
filename, lineno = events._get_function_source(coro.func)
if coro.gi_frame is None:
- coro_repr = '%s() done, defined at %s:%s' % (coro_name, filename, lineno)
+ coro_repr = ('%s() done, defined at %s:%s'
+ % (coro_name, filename, lineno))
else:
- coro_repr = '%s() running, defined at %s:%s' % (coro_name, filename, lineno)
+ coro_repr = ('%s() running, defined at %s:%s'
+ % (coro_name, filename, lineno))
elif coro.gi_frame is not None:
lineno = coro.gi_frame.f_lineno
- coro_repr = '%s() running at %s:%s' % (coro_name, filename, lineno)
+ coro_repr = ('%s() running at %s:%s'
+ % (coro_name, filename, lineno))
else:
lineno = coro.gi_code.co_firstlineno
- coro_repr = '%s() done, defined at %s:%s' % (coro_name, filename, lineno)
+ coro_repr = ('%s() done, defined at %s:%s'
+ % (coro_name, filename, lineno))
return coro_repr
diff --git a/Lib/asyncio/selector_events.py b/Lib/asyncio/selector_events.py
index 2e7364b8c8..69b649ceea 100644
--- a/Lib/asyncio/selector_events.py
+++ b/Lib/asyncio/selector_events.py
@@ -55,8 +55,8 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
return _SelectorSocketTransport(self, sock, protocol, waiter,
extra, server)
- def _make_ssl_transport(self, rawsock, protocol, sslcontext, waiter=None, *,
- server_side=False, server_hostname=None,
+ def _make_ssl_transport(self, rawsock, protocol, sslcontext, waiter=None,
+ *, server_side=False, server_hostname=None,
extra=None, server=None):
return _SelectorSslTransport(
self, rawsock, protocol, sslcontext, waiter,
@@ -484,7 +484,8 @@ class _SelectorTransport(transports._FlowControlMixin,
info.append('read=idle')
polling = _test_selector_event(self._loop._selector,
- self._sock_fd, selectors.EVENT_WRITE)
+ self._sock_fd,
+ selectors.EVENT_WRITE)
if polling:
state = 'polling'
else:
diff --git a/Lib/asyncio/tasks.py b/Lib/asyncio/tasks.py
index 9aebffdaba..8fc5beacf9 100644
--- a/Lib/asyncio/tasks.py
+++ b/Lib/asyncio/tasks.py
@@ -68,7 +68,7 @@ class Task(futures.Future):
return {t for t in cls._all_tasks if t._loop is loop}
def __init__(self, coro, *, loop=None):
- assert coroutines.iscoroutine(coro), repr(coro) # Not a coroutine function!
+ assert coroutines.iscoroutine(coro), repr(coro)
super().__init__(loop=loop)
if self._source_traceback:
del self._source_traceback[-1]
diff --git a/Lib/asyncio/unix_events.py b/Lib/asyncio/unix_events.py
index d1461fd024..91e43cfc97 100644
--- a/Lib/asyncio/unix_events.py
+++ b/Lib/asyncio/unix_events.py
@@ -69,7 +69,8 @@ class _UnixSelectorEventLoop(selector_events.BaseSelectorEventLoop):
"""
if (coroutines.iscoroutine(callback)
or coroutines.iscoroutinefunction(callback)):
- raise TypeError("coroutines cannot be used with add_signal_handler()")
+ raise TypeError("coroutines cannot be used "
+ "with add_signal_handler()")
self._check_signal(sig)
self._check_closed()
try:
diff --git a/Lib/asyncio/windows_events.py b/Lib/asyncio/windows_events.py
index d7feb1aec8..9d496f2f47 100644
--- a/Lib/asyncio/windows_events.py
+++ b/Lib/asyncio/windows_events.py
@@ -424,7 +424,8 @@ class IocpProactor:
else:
return windows_utils.PipeHandle(handle)
- return self._register(ov, None, finish_connect_pipe, wait_for_post=True)
+ return self._register(ov, None, finish_connect_pipe,
+ wait_for_post=True)
def wait_for_handle(self, handle, timeout=None):
"""Wait for a handle.
diff --git a/Lib/asyncio/windows_utils.py b/Lib/asyncio/windows_utils.py
index c6e4bc9e46..b47581235c 100644
--- a/Lib/asyncio/windows_utils.py
+++ b/Lib/asyncio/windows_utils.py
@@ -36,15 +36,16 @@ else:
def socketpair(family=socket.AF_INET, type=socket.SOCK_STREAM, proto=0):
"""A socket pair usable as a self-pipe, for Windows.
- Origin: https://gist.github.com/4325783, by Geert Jansen. Public domain.
+ Origin: https://gist.github.com/4325783, by Geert Jansen.
+ Public domain.
"""
if family == socket.AF_INET:
host = '127.0.0.1'
elif family == socket.AF_INET6:
host = '::1'
else:
- raise ValueError("Only AF_INET and AF_INET6 socket address families "
- "are supported")
+ raise ValueError("Only AF_INET and AF_INET6 socket address "
+ "families are supported")
if type != socket.SOCK_STREAM:
raise ValueError("Only SOCK_STREAM socket type is supported")
if proto != 0:
View Lorry Controller Status