use crate::{decode, encode, io::ReadError};
use futures_io::AsyncRead;
use futures_util::io::AsyncReadExt;
use std::io;
macro_rules! gen {
($($name:ident, $d:expr, $t:ident, $b:ident);*) => {
$(
#[doc = " Try to read and decode a "]
#[doc = $d]
#[doc = " from the given `AsyncRead` type."]
pub async fn $name<R: AsyncRead + Unpin>(mut reader: R) -> Result<$t, ReadError> {
let mut b = encode::$b();
for i in 0 .. b.len() {
let n = reader.read(&mut b[i .. i + 1]).await?;
if n == 0 {
return Err(ReadError::Io(io::ErrorKind::UnexpectedEof.into()))
}
if decode::is_last(b[i]) {
return Ok(decode::$t(&b[..= i])?.0)
}
}
Err(decode::Error::Overflow)?
}
)*
}
}
gen! {
read_u8, "`u8`", u8, u8_buffer;
read_u16, "`u16`", u16, u16_buffer;
read_u32, "`u32`", u32, u32_buffer;
read_u64, "`u64`", u64, u64_buffer;
read_u128, "`u128`", u128, u128_buffer;
read_usize, "`usize`", usize, usize_buffer
}