diff options
author | Yury Selivanov <yselivanov@sprymix.com> | 2014-02-20 19:10:02 (GMT) |
---|---|---|
committer | Yury Selivanov <yselivanov@sprymix.com> | 2014-02-20 19:10:02 (GMT) |
commit | 35669ae77ef4c501f09b1620bd3137dd5931868c (patch) | |
tree | 1a7c6509020a57d7d08f6c856c7c8bb3c7f2e801 /Doc/library | |
parent | cd153f8bddcd31e513c02617e93182a0b481e4a6 (diff) | |
download | cpython-35669ae77ef4c501f09b1620bd3137dd5931868c.zip cpython-35669ae77ef4c501f09b1620bd3137dd5931868c.tar.gz cpython-35669ae77ef4c501f09b1620bd3137dd5931868c.tar.bz2 |
asyncio.docs: Improve documentation of Streams. Issue #20696.
Diffstat (limited to 'Doc/library')
-rw-r--r-- | Doc/library/asyncio-stream.rst | 72 |
1 files changed, 43 insertions, 29 deletions
diff --git a/Doc/library/asyncio-stream.rst b/Doc/library/asyncio-stream.rst index f557df3..76b6643 100644 --- a/Doc/library/asyncio-stream.rst +++ b/Doc/library/asyncio-stream.rst @@ -34,7 +34,7 @@ Stream functions .. function:: start_server(client_connected_cb, host=None, port=None, \*, loop=None, limit=None, **kwds) - Start a socket server, call back for each client connected. + Start a socket server, with a callback for each client connected. The first parameter, *client_connected_cb*, takes two parameters: *client_reader*, *client_writer*. *client_reader* is a @@ -58,6 +58,29 @@ Stream functions This function returns a :ref:`coroutine object <coroutine>`. +.. function:: open_unix_connection(path=None, \*, loop=None, limit=None, **kwds) + + A wrapper for :meth:`~BaseEventLoop.create_unix_connection()` returning + a (reader, writer) pair. + + See :func:`open_connection` for information about return value and other + details. + + This function returns a :ref:`coroutine object <coroutine>`. + + Availability: UNIX. + +.. function:: start_unix_server(client_connected_cb, path=None, \*, loop=None, limit=None, **kwds) + + Start a UNIX Domain Socket server, with a callback for each client connected. + + See :func:`start_server` for information about return value and other + details. + + This function returns a :ref:`coroutine object <coroutine>`. + + Availability: UNIX. + StreamReader ============ @@ -70,11 +93,12 @@ StreamReader .. method:: feed_eof() - XXX + Acknowledge the EOF. .. method:: feed_data(data) - XXX + Feed *data* bytes in the internal buffer. Any operations waiting + for the data will be resumed. .. method:: set_exception(exc) @@ -86,13 +110,23 @@ StreamReader .. method:: read(n=-1) - XXX + Read up to *n* bytes. If *n* is not provided, or set to ``-1``, + read until EOF and return all read bytes. + + If the EOF was received and the internal buffer is empty, + return an empty ``bytes`` object. This method returns a :ref:`coroutine object <coroutine>`. .. method:: readline() - XXX + Read one line, where "line" is a sequence of bytes ending with ``\n``. + + If EOF is received, and ``\n`` was not found, the method will + return the partial read bytes. + + If the EOF was received and the internal buffer is empty, + return an empty ``bytes`` object. This method returns a :ref:`coroutine object <coroutine>`. @@ -105,6 +139,10 @@ StreamReader This method returns a :ref:`coroutine object <coroutine>`. + .. method:: at_eof() + + Return ``True`` if the buffer is empty and :meth:`feed_eof` was called. + StreamWriter ============ @@ -186,30 +224,6 @@ StreamReaderProtocol potential uses, and to prevent the user of the :class:`StreamReader` to accidentally call inappropriate methods of the protocol.) - .. method:: connection_made(transport) - - XXX - - .. method:: connection_lost(exc) - - XXX - - .. method:: data_received(data) - - XXX - - .. method:: eof_received() - - XXX - - .. method:: pause_writing() - - XXX - - .. method:: resume_writing() - - XXX - IncompleteReadError =================== |