diff options
author | Miss Islington (bot) <31488909+miss-islington@users.noreply.github.com> | 2023-02-03 07:26:05 (GMT) |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-02-03 07:26:05 (GMT) |
commit | 4c732bc425976194ae1309753f89aa43b64582fa (patch) | |
tree | c57c1219c37e689508c41a3cd09defbc4546f956 /Doc | |
parent | c3dd95a669030ff81f5e841d181110cdfd78e542 (diff) | |
download | cpython-4c732bc425976194ae1309753f89aa43b64582fa.zip cpython-4c732bc425976194ae1309753f89aa43b64582fa.tar.gz cpython-4c732bc425976194ae1309753f89aa43b64582fa.tar.bz2 |
gh-100920: Update documentation for `asyncio.StreamWriter.wait_closed` (GH-101514)
(cherry picked from commit 5c39daf50b7f388f9b24bb2d6ef415955440bebf)
Co-authored-by: Viet Than <thanhoangviet@gmail.com>
Diffstat (limited to 'Doc')
-rw-r--r-- | Doc/library/asyncio-stream.rst | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/Doc/library/asyncio-stream.rst b/Doc/library/asyncio-stream.rst index bed10a4..f0fcac1 100644 --- a/Doc/library/asyncio-stream.rst +++ b/Doc/library/asyncio-stream.rst @@ -281,7 +281,8 @@ StreamWriter The method closes the stream and the underlying socket. - The method should be used along with the ``wait_closed()`` method:: + The method should be used, though not mandatory, + along with the ``wait_closed()`` method:: stream.close() await stream.wait_closed() @@ -332,7 +333,8 @@ StreamWriter Wait until the stream is closed. Should be called after :meth:`close` to wait until the underlying - connection is closed. + connection is closed, ensuring that all data has been flushed + before e.g. exiting the program. .. versionadded:: 3.7 @@ -361,6 +363,7 @@ TCP echo client using the :func:`asyncio.open_connection` function:: print('Close the connection') writer.close() + await writer.wait_closed() asyncio.run(tcp_echo_client('Hello World!')) @@ -393,6 +396,7 @@ TCP echo server using the :func:`asyncio.start_server` function:: print("Close the connection") writer.close() + await writer.wait_closed() async def main(): server = await asyncio.start_server( @@ -449,6 +453,7 @@ Simple example querying HTTP headers of the URL passed on the command line:: # Ignore the body, close the socket writer.close() + await writer.wait_closed() url = sys.argv[1] asyncio.run(print_http_headers(url)) @@ -494,6 +499,7 @@ Coroutine waiting until a socket receives data using the # Got data, we are done: close the socket print("Received:", data.decode()) writer.close() + await writer.wait_closed() # Close the second socket wsock.close() |