itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-10-01 12:20:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

io: flush in AsyncWriteExt examples (#6149)

Browse Source 
Closes: #6068
This commit is contained in:
Alice Ryhl 2023-11-14 20:13:00 +01:00 committed by GitHub
parent 2e5773a6fe
commit 06660ef00a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
tokio/src/io/util/async_write_ext.rs
View File

@ -117,6 +117,7 @@ cfg_io_util! {
/// ///
/// // Writes some prefix of the byte string, not necessarily all of it. /// // Writes some prefix of the byte string, not necessarily all of it.
/// file.write(b"some bytes").await?; /// file.write(b"some bytes").await?;
/// file.flush().await?;
/// Ok(()) /// Ok(())
/// } /// }
/// ``` /// ```
@ -162,6 +163,7 @@ cfg_io_util! {
/// ]; /// ];
/// ///
/// file.write_vectored(&bufs).await?; /// file.write_vectored(&bufs).await?;
/// file.flush().await?;
/// ///
/// Ok(()) /// Ok(())
/// } /// }
@ -244,6 +246,7 @@ cfg_io_util! {
/// // all of it. /// // all of it.
/// file.write_buf(&mut buffer).await?; /// file.write_buf(&mut buffer).await?;
/// } /// }
/// file.flush().await?;
/// ///
/// Ok(()) /// Ok(())
/// } /// }
@ -307,6 +310,7 @@ cfg_io_util! {
/// let mut buffer = Cursor::new(b"data to write"); /// let mut buffer = Cursor::new(b"data to write");
/// ///
/// file.write_all_buf(&mut buffer).await?; /// file.write_all_buf(&mut buffer).await?;
/// file.flush().await?;
/// Ok(()) /// Ok(())
/// } /// }
/// ``` /// ```
@ -356,6 +360,7 @@ cfg_io_util! {
/// let mut file = File::create("foo.txt").await?; /// let mut file = File::create("foo.txt").await?;
/// ///
/// file.write_all(b"some bytes").await?; /// file.write_all(b"some bytes").await?;
/// file.flush().await?;
/// Ok(()) /// Ok(())
/// } /// }
/// ``` /// ```