mirror of
https://github.com/tokio-rs/tokio.git
synced 2025-09-25 12:00:35 +00:00
fs: add fs::copy (#2079)
Provides an asynchronous version of `std::fs::copy`. Closes: #2076
This commit is contained in:
parent
968c143acd
commit
f0bfebb7e1
@ -49,7 +49,7 @@ full = [
|
||||
|
||||
blocking = ["rt-core"]
|
||||
dns = ["rt-core"]
|
||||
fs = ["rt-core"]
|
||||
fs = ["rt-core", "io-util"]
|
||||
io-driver = ["mio", "lazy_static"]
|
||||
io-util = ["memchr"]
|
||||
# stdin, stdout, stderr
|
||||
|
26
tokio/src/fs/copy.rs
Normal file
26
tokio/src/fs/copy.rs
Normal file
@ -0,0 +1,26 @@
|
||||
use crate::fs::File;
|
||||
use crate::io;
|
||||
use std::path::Path;
|
||||
|
||||
/// Copies the contents of one file to another. This function will also copy the permission bits of the original file to the destination file.
|
||||
/// This function will overwrite the contents of to.
|
||||
///
|
||||
/// This is the async equivalent of `std::fs::copy`.
|
||||
///
|
||||
/// # Examples
|
||||
///
|
||||
/// ```no_run
|
||||
/// use tokio::fs;
|
||||
///
|
||||
/// # async fn dox() -> std::io::Result<()> {
|
||||
/// fs::copy("foo.txt", "bar.txt").await?;
|
||||
/// # Ok(())
|
||||
/// # }
|
||||
/// ```
|
||||
|
||||
pub async fn copy<P: AsRef<Path>, Q: AsRef<Path>>(from: P, to: Q) -> Result<u64, std::io::Error> {
|
||||
let from = File::open(from).await?;
|
||||
let to = File::create(to).await?;
|
||||
let (mut from, mut to) = (io::BufReader::new(from), io::BufWriter::new(to));
|
||||
io::copy(&mut from, &mut to).await
|
||||
}
|
@ -80,6 +80,9 @@ pub use self::symlink_metadata::symlink_metadata;
|
||||
mod write;
|
||||
pub use self::write::write;
|
||||
|
||||
mod copy;
|
||||
pub use self::copy::copy;
|
||||
|
||||
use std::io;
|
||||
|
||||
pub(crate) async fn asyncify<F, T>(f: F) -> io::Result<T>
|
||||
|
15
tokio/tests/fs_copy.rs
Normal file
15
tokio/tests/fs_copy.rs
Normal file
@ -0,0 +1,15 @@
|
||||
#![warn(rust_2018_idioms)]
|
||||
#![cfg(feature = "full")]
|
||||
|
||||
use tokio::fs;
|
||||
|
||||
#[tokio::test]
|
||||
async fn copy() {
|
||||
fs::write("foo.txt", b"Hello File!").await.unwrap();
|
||||
fs::copy("foo.txt", "bar.txt").await.unwrap();
|
||||
|
||||
let from = fs::read("foo.txt").await.unwrap();
|
||||
let to = fs::read("bar.txt").await.unwrap();
|
||||
|
||||
assert_eq!(from, to);
|
||||
}
|
Loading…
x
Reference in New Issue
Block a user