14 releases
0.2.3 | Sep 27, 2022 |
---|---|
0.2.2 | Jan 19, 2021 |
0.1.9 | Dec 31, 2020 |
0.1.7 | Jun 22, 2020 |
#728 in Asynchronous
Used in 2 crates
38KB
771 lines
Straightforward Linux AIO using Futures/async/await.
Example
Use aiofut to schedule writes to a file:
use futures::{executor::LocalPool, future::FutureExt, task::LocalSpawnExt};
use aiofut::AIOBuilder;
use std::os::unix::io::AsRawFd;
let mut aiomgr = AIOBuilder::default().build().unwrap();
let file = std::fs::OpenOptions::new()
.read(true)
.write(true)
.create(true)
.truncate(true)
.open("test")
.unwrap();
let fd = file.as_raw_fd();
// keep all returned futures in a vector
let ws = vec![(0, "hello"), (5, "world"), (2, "xxxx")]
.into_iter()
.map(|(off, s)| aiomgr.write(fd, off, s.as_bytes().into(), None))
.collect::<Vec<_>>();
// here we use futures::executor::LocalPool to poll all futures
let mut pool = LocalPool::new();
let spawner = pool.spawner();
for w in ws.into_iter() {
let h = spawner.spawn_local_with_handle(w).unwrap().map(|r| {
println!("wrote {} bytes", r.0.unwrap());
});
spawner.spawn_local(h).unwrap();
}
pool.run();
Dependencies
~0.7–5.5MB
~16K SLoC