Struct zarrs::array::codec::AsyncStoragePartialDecoder

pub struct AsyncStoragePartialDecoder { /* private fields */ }

Available on crate feature async only.

An AsyncReadableStorage store value partial decoder.

Implementations

impl AsyncStoragePartialDecoder

pub fn new(storage: AsyncReadableStorage, key: StoreKey) -> Self

Create a new storage partial decoder.

Trait Implementations

impl AsyncBytesPartialDecoderTraits for AsyncStoragePartialDecoder

fn partial_decode<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, decoded_regions: &'life1 [ByteRange], _options: &'life2 CodecOptions ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<Vec<u8>>>, CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Partially decode bytes.

fn partial_decode_concat<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, decoded_regions: &'life1 [ByteRange], options: &'life2 CodecOptions ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Partially decode bytes and concatenate.

fn decode<'life0, 'life1, 'async_trait>( &'life0 self, options: &'life1 CodecOptions ) -> Pin<Box<dyn Future<Output = Result<MaybeBytes, CodecError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Decode all bytes.