Trait AsyncDataSource

pub trait AsyncDataSource<A>:
    DynClone
    + Debug
    + Sync
    + Send
where
    A: Digest,
{
    // Required methods
    fn slice(
        &self,
        size: PartSize,
    ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send + '_>>;
    fn reset(
        &self,
    ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>;
    fn source_key(
        &self,
    ) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send + '_>>;
    fn total_size(
        &self,
    ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send + '_>>;
}

异步数据源接口

提供上传所用的数据源

Required Methods

fn slice( &self, size: PartSize, ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send + '_>>

异步数据源切片

fn reset(&self) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>

异步重置数据源

fn source_key( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send + '_>>

异步获取数据源 KEY

用于区分不同的数据源

fn total_size( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send + '_>>

异步获取数据源大小

Trait Implementations

impl<'clone, A> Clone for Box<dyn AsyncDataSource<A> + 'clone>

where A: Digest,

fn clone(&self) -> Box<dyn AsyncDataSource<A> + 'clone>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'clone, A> Clone for Box<dyn AsyncDataSource<A> + Send + 'clone>

where A: Digest,

fn clone(&self) -> Box<dyn AsyncDataSource<A> + Send + 'clone>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'clone, A> Clone for Box<dyn AsyncDataSource<A> + Sync + Send + 'clone>

where A: Digest,

fn clone(&self) -> Box<dyn AsyncDataSource<A> + Sync + Send + 'clone>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'clone, A> Clone for Box<dyn AsyncDataSource<A> + Sync + 'clone>

where A: Digest,

fn clone(&self) -> Box<dyn AsyncDataSource<A> + Sync + 'clone>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

Implementations on Foreign Types

impl<'a, A, T> AsyncDataSource<A> for &'a T

where A: Digest, T: 'a + AsyncDataSource<A> + ?Sized, &'a T: DynClone + Debug + Sync + Send,

fn slice( &self, size: PartSize, ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send + '_>>

fn reset(&self) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>

fn source_key( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send + '_>>

fn total_size( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send + '_>>

impl<'a, A, T> AsyncDataSource<A> for &'a mut T

where A: Digest, T: 'a + AsyncDataSource<A> + ?Sized, &'a mut T: DynClone + Debug + Sync + Send,

fn slice( &self, size: PartSize, ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send + '_>>

fn reset(&self) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>

fn source_key( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send + '_>>

fn total_size( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send + '_>>

impl<A, T> AsyncDataSource<A> for Box<T>

where A: Digest, T: AsyncDataSource<A> + ?Sized, Box<T>: DynClone + Debug + Sync + Send,

fn slice( &self, size: PartSize, ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send + '_>>

fn reset(&self) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>

fn source_key( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send + '_>>

fn total_size( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send + '_>>

impl<A, T> AsyncDataSource<A> for Rc<T>

where A: Digest, T: AsyncDataSource<A> + ?Sized, Rc<T>: DynClone + Debug + Sync + Send,

fn slice( &self, size: PartSize, ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send + '_>>

fn reset(&self) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>

fn source_key( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send + '_>>

fn total_size( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send + '_>>

impl<A, T> AsyncDataSource<A> for Arc<T>

where A: Digest, T: AsyncDataSource<A> + ?Sized, Arc<T>: DynClone + Debug + Sync + Send,

fn slice( &self, size: PartSize, ) -> Pin<Box<dyn Future<Output = Result<Option<AsyncDataSourceReader>, Error>> + Send + '_>>

fn reset(&self) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + '_>>

fn source_key( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<SourceKey<A>>, Error>> + Send + '_>>

fn total_size( &self, ) -> Pin<Box<dyn Future<Output = Result<Option<u64>, Error>> + Send + '_>>

Implementors

impl<A> AsyncDataSource<A> for AsyncFileDataSource<A>

where A: Digest + Send,

impl<R, A> AsyncDataSource<A> for AsyncUnseekableDataSource<R, A>

where R: AsyncRead + Debug + Unpin + Send + Sync + 'static, A: Digest,