microasync_util/io/write/
mod.rs

1extern crate std;
2
3use core::future::Future;
4use std::io;
5
6pub struct WriteFuture<'a, T>(&'a mut T, &'a [u8]);
7
8pub struct WriteExactFuture<'a, T>(&'a mut T, &'a [u8]);
9
10/// Trait that adds async variants of some std::io::Write functions.
11pub trait WriteAsync<'a, T, FWrite, FWriteExact>
12where
13    FWrite: Future<Output = Result<usize, io::Error>> + 'a,
14{
15    /// Async equivalent to std::io::Write::write.
16    fn write(&'a mut self, bytes: &'a [u8]) -> FWrite;
17
18    /// Async equivalent to std::io::Write::write_exact. When using UDP, this may send multiple
19    /// packets.
20    fn write_exact(&'a mut self, bytes: &'a [u8]) -> FWriteExact;
21}
22
23impl<'a, T> WriteAsync<'a, usize, WriteFuture<'a, T>, WriteExactFuture<'a, T>> for T
24where
25    WriteFuture<'a, T>: Future<Output = Result<usize, io::Error>> + 'a,
26    WriteExactFuture<'a, T>: Future<Output = Result<(), io::Error>> + 'a,
27{
28    fn write(&'a mut self, bytes: &'a [u8]) -> WriteFuture<'a, T> {
29        WriteFuture(self, bytes)
30    }
31
32    fn write_exact(&'a mut self, bytes: &'a [u8]) -> WriteExactFuture<'a, T> {
33        WriteExactFuture(self, bytes)
34    }
35}
36
37pub mod file;
38pub mod tcpstream;
39pub mod udpsocket;
microasync_util/io/write/mod.rs

microasync_util/io/write/
mod.rs
