Commit 9143071d authored by Yury Selivanov's avatar Yury Selivanov

asyncio: Fix spelling and typos.

Thanks to Vajrasky Kok for discovering some of them.
parent 7f8edcaf
......@@ -235,7 +235,7 @@ class AbstractEventLoop:
sock=None, backlog=100, ssl=None):
"""A coroutine which creates a UNIX Domain Socket server.
The return valud is a Server object, which can be used to stop
The return value is a Server object, which can be used to stop
the service.
path is a str, representing a file systsem path to bind the
......@@ -260,7 +260,7 @@ class AbstractEventLoop:
# Pipes and subprocesses.
def connect_read_pipe(self, protocol_factory, pipe):
"""Register read pipe in eventloop.
"""Register read pipe in event loop.
protocol_factory should instantiate object with Protocol interface.
pipe is file-like object already switched to nonblocking.
......@@ -273,7 +273,7 @@ class AbstractEventLoop:
raise NotImplementedError
def connect_write_pipe(self, protocol_factory, pipe):
"""Register write pipe in eventloop.
"""Register write pipe in event loop.
protocol_factory should instantiate object with BaseProtocol interface.
Pipe is file-like object already switched to nonblocking.
......
......@@ -114,7 +114,7 @@ class SubprocessProtocol(BaseProtocol):
def pipe_data_received(self, fd, data):
"""Called when the subprocess writes data into stdout/stderr pipe.
fd is int file dascriptor.
fd is int file descriptor.
data is bytes object.
"""
......
......@@ -213,7 +213,7 @@ class BaseSelectorEventLoop(base_events.BaseEventLoop):
def _sock_recv(self, fut, registered, sock, n):
# _sock_recv() can add itself as an I/O callback if the operation can't
# be done immediatly. Don't use it directly, call sock_recv().
# be done immediately. Don't use it directly, call sock_recv().
fd = sock.fileno()
if registered:
# Remove the callback early. It should be rare that the
......
......@@ -181,7 +181,7 @@ class Task(futures.Future):
The frames are always ordered from oldest to newest.
The optional limit gives the maximum nummber of frames to
The optional limit gives the maximum number of frames to
return; by default all available frames are returned. Its
meaning differs depending on whether a stack or a traceback is
returned: the newest frames of a stack are returned, but the
......
......@@ -259,7 +259,7 @@ class TestLoop(base_events.BaseEventLoop):
when = yield ...
... = yield time_advance
Value retuned by yield is absolute time of next scheduled handler.
Value returned by yield is absolute time of next scheduled handler.
Value passed to yield is time advance to move loop's time forward.
"""
......@@ -369,7 +369,7 @@ class MockPattern(str):
"""A regex based str with a fuzzy __eq__.
Use this helper with 'mock.assert_called_with', or anywhere
where a regexp comparison between strings is needed.
where a regex comparison between strings is needed.
For instance:
mock_call.assert_called_with(MockPattern('spam.*ham'))
......
"""Selector eventloop for Unix with signal handling."""
"""Selector event loop for Unix with signal handling."""
import errno
import fcntl
......@@ -244,7 +244,7 @@ def _set_nonblocking(fd):
class _UnixReadPipeTransport(transports.ReadTransport):
max_size = 256 * 1024 # max bytes we read in one eventloop iteration
max_size = 256 * 1024 # max bytes we read in one event loop iteration
def __init__(self, loop, pipe, protocol, waiter=None, extra=None):
super().__init__(extra)
......
"""Selector and proactor eventloops for Windows."""
"""Selector and proactor event loops for Windows."""
import _winapi
import errno
......
......@@ -80,7 +80,7 @@ class BaseSelector(metaclass=ABCMeta):
A selector can use various implementations (select(), poll(), epoll()...)
depending on the platform. The default `Selector` class uses the most
performant implementation on the current platform.
efficient implementation on the current platform.
"""
@abstractmethod
......
......@@ -277,7 +277,7 @@ class BaseEventLoopTests(unittest.TestCase):
asyncio.SubprocessProtocol, *args, bufsize=4096)
def test_subprocess_shell_invalid_args(self):
# exepected a string, not an int or a list
# expected a string, not an int or a list
self.assertRaises(TypeError,
self.loop.run_until_complete, self.loop.subprocess_shell,
asyncio.SubprocessProtocol, 123)
......
......@@ -503,7 +503,6 @@ class EventLoopTestsMixin:
tr, pr = self.loop.run_until_complete(connection_fut)
self.assertIsInstance(tr, asyncio.Transport)
self.assertIsInstance(pr, asyncio.Protocol)
self.assertIsNotNone(tr.get_extra_info('sockname'))
self.loop.run_until_complete(pr.done)
self.assertGreater(pr.nbytes, 0)
tr.close()
......
......@@ -38,7 +38,7 @@ class FutureTests(unittest.TestCase):
asyncio.set_event_loop(None)
def test_constructor_positional(self):
# Make sure Future does't accept a positional argument
# Make sure Future doesn't accept a positional argument
self.assertRaises(TypeError, asyncio.Future, 42)
def test_cancel(self):
......
......@@ -239,7 +239,7 @@ class StreamReaderTests(unittest.TestCase):
# No b'\n' at the end. The 'limit' is set to 3. So before
# waiting for the new data in buffer, 'readline' will consume
# the entire buffer, and since the length of the consumed data
# is more than 3, it will raise a ValudError. The buffer is
# is more than 3, it will raise a ValueError. The buffer is
# expected to be empty now.
self.assertEqual(b'', stream._buffer)
......
......@@ -965,7 +965,7 @@ class ChildWatcherTestsMixin:
self.assertFalse(m.WEXITSTATUS.called)
self.assertFalse(m.WTERMSIG.called)
# childen are running
# children are running
self.watcher._sig_chld()
self.assertFalse(callback1.called)
......@@ -1069,7 +1069,7 @@ class ChildWatcherTestsMixin:
self.assertFalse(m.WEXITSTATUS.called)
self.assertFalse(m.WTERMSIG.called)
# childen are running
# children are running
self.watcher._sig_chld()
self.assertFalse(callback1.called)
......@@ -1425,7 +1425,7 @@ class ChildWatcherTestsMixin:
self.add_zombie(61, 11)
self.add_zombie(62, -5)
# SIGCHLD was not catched
# SIGCHLD was not caught
self.assertFalse(callback1.called)
self.assertFalse(callback2.called)
self.assertFalse(callback3.called)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment