diff options
Diffstat (limited to 'third_party/rust/tokio-fs/src/create_dir.rs')
-rw-r--r-- | third_party/rust/tokio-fs/src/create_dir.rs | 46 |
1 files changed, 46 insertions, 0 deletions
diff --git a/third_party/rust/tokio-fs/src/create_dir.rs b/third_party/rust/tokio-fs/src/create_dir.rs new file mode 100644 index 0000000000..a174a5d97f --- /dev/null +++ b/third_party/rust/tokio-fs/src/create_dir.rs @@ -0,0 +1,46 @@ +use std::fs; +use std::io; +use std::path::Path; + +use futures::{Future, Poll}; + +/// Creates a new, empty directory at the provided path +/// +/// This is an async version of [`std::fs::create_dir`][std] +/// +/// [std]: https://doc.rust-lang.org/std/fs/fn.create_dir.html +pub fn create_dir<P: AsRef<Path>>(path: P) -> CreateDirFuture<P> { + CreateDirFuture::new(path) +} + +/// Future returned by `create_dir`. +#[derive(Debug)] +pub struct CreateDirFuture<P> +where + P: AsRef<Path> +{ + path: P, +} + +impl<P> CreateDirFuture<P> +where + P: AsRef<Path> +{ + fn new(path: P) -> CreateDirFuture<P> { + CreateDirFuture { + path: path, + } + } +} + +impl<P> Future for CreateDirFuture<P> +where + P: AsRef<Path> +{ + type Item = (); + type Error = io::Error; + + fn poll(&mut self) -> Poll<Self::Item, Self::Error> { + ::blocking_io(|| fs::create_dir(&self.path) ) + } +} |