1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77
pub use { async_trait::async_trait, bitreader_async::BitReader, async_std::io::Read }; use bitreader_async::error::*; #[async_trait] pub trait FromBitReader<E, R> where Self : Sized, R : Read + std::marker::Unpin + std::marker::Send { async fn from_bitreader(reader : &mut BitReader<R>) -> std::result::Result<Self, E>; } #[async_trait] pub trait FromBitReaderWithLength<E, R> where Self : Sized, R : Read + std::marker::Unpin + std::marker::Send { async fn from_bitreader_with_length(reader : &mut BitReader<R>, len : usize) -> std::result::Result<Self, E>; } #[async_trait] impl<R> FromBitReader<BitReaderError, R> for () where R : Read + std::marker::Unpin + std::marker::Send { async fn from_bitreader(_reader : &mut BitReader<R>) -> Result<()> { Ok(()) } } #[async_trait] impl<R> FromBitReader<BitReaderError, R> for bool where R : Read + std::marker::Unpin + std::marker::Send { async fn from_bitreader(reader : &mut BitReader<R>) -> Result<bool> { Ok(reader.read_be_bits(1).await? != 0) } } #[async_trait] impl<R> FromBitReader<BitReaderError, R> for u8 where R : Read + std::marker::Unpin + std::marker::Send { async fn from_bitreader(reader : &mut BitReader<R>) -> Result<u8> { Ok(reader.read_aligned_be::<u8>().await?) } } #[async_trait] impl<R> FromBitReader<BitReaderError, R> for u16 where R : Read + std::marker::Unpin + std::marker::Send { async fn from_bitreader(reader : &mut BitReader<R>) -> Result<u16> { Ok(reader.read_aligned_be::<u16>().await?) } } #[async_trait] impl<R> FromBitReader<BitReaderError, R> for u32 where R : Read + std::marker::Unpin + std::marker::Send { async fn from_bitreader(reader : &mut BitReader<R>) -> Result<u32> { Ok(reader.read_aligned_be::<u32>().await?) } } #[async_trait] impl<R> FromBitReaderWithLength<BitReaderError, R> for Vec<u8> where R : Read + std::marker::Unpin + std::marker::Send { async fn from_bitreader_with_length(reader : &mut BitReader<R>, len : usize) -> Result<Vec<u8>> { Ok(reader.read_u8_slice_aligned(len).await?) } }