Struct VecReader

pub struct VecReader { /* private fields */ }

An AsyncRead implementation capable of reading a Vec<u8>.

Implementations

impl VecReader

pub fn new(bytes: Vec<u8>) -> VecReader

Create a new VecReader for bytes.

Examples found in repository

examples/asset/asset_decompression.rs (line 72)

    async fn load(
        &self,
        reader: &mut dyn Reader,
        _settings: &(),
        load_context: &mut LoadContext<'_>,
    ) -> Result<Self::Asset, Self::Error> {
        let compressed_path = load_context.path();
        let file_name = compressed_path
            .file_name()
            .ok_or(GzAssetLoaderError::IndeterminateFilePath)?
            .to_string_lossy();
        let uncompressed_file_name = file_name
            .strip_suffix(".gz")
            .ok_or(GzAssetLoaderError::IndeterminateFilePath)?;
        let contained_path = compressed_path.join(uncompressed_file_name);

        let mut bytes_compressed = Vec::new();

        reader.read_to_end(&mut bytes_compressed).await?;

        let mut decoder = GzDecoder::new(bytes_compressed.as_slice());

        let mut bytes_uncompressed = Vec::new();

        decoder.read_to_end(&mut bytes_uncompressed)?;

        // Now that we have decompressed the asset, let's pass it back to the
        // context to continue loading

        let mut reader = VecReader::new(bytes_uncompressed);

        let uncompressed = load_context
            .loader()
            .with_unknown_type()
            .immediate()
            .with_reader(&mut reader)
            .load(contained_path)
            .await?;

        Ok(GzAsset { uncompressed })
    }

Trait Implementations

impl AsyncRead for VecReader

fn poll_read( self: Pin<&mut VecReader>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl AsyncSeekForward for VecReader

fn poll_seek_forward( self: Pin<&mut VecReader>, _cx: &mut Context<'_>, offset: u64, ) -> Poll<Result<u64, Error>>

Attempts to asynchronously seek forward by a specified number of bytes from the current cursor position.

impl Reader for VecReader

fn read_to_end<'a>( &'a mut self, buf: &'a mut Vec<u8>, ) -> StackFuture<'a, Result<usize, Error>, bevy_asset::::io::{impl#14}::read_to_end::{constant#0}>

Reads the entire contents of this reader and appends them to a vec.