asyncio: Fix spelling and typos.

Thanks to Vajrasky Kok for discovering some of them.
This commit is contained in:
Yury Selivanov 2014-02-18 22:27:48 -05:00
parent 8abac348a9
commit b0b0e628ee
13 changed files with 18 additions and 19 deletions

View File

@ -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.

View File

@ -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.
"""

View File

@ -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

View File

@ -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

View File

@ -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'))

View File

@ -1,4 +1,4 @@
"""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)

View File

@ -1,4 +1,4 @@
"""Selector and proactor eventloops for Windows."""
"""Selector and proactor event loops for Windows."""
import _winapi
import errno

View File

@ -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

View File

@ -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)

View File

@ -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()

View File

@ -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):

View File

@ -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)

View File

@ -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)