Trait qiniu_sdk::prelude::AsyncDataSource

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

异步数据源接口

提供上传所用的数据源

Required Methods

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

异步数据源切片

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

异步重置数据源

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

异步获取数据源 KEY

用于区分不同的数据源

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

异步获取数据源大小

Implementations on Foreign Types

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, Global>>

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

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

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

impl<'a, A, T> AsyncDataSource<A> for &'a Twhere
    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, Global>>

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

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

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

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, Global>>

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

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

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

impl<'a, A, T> AsyncDataSource<A> for &'a mut Twhere
    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, Global>>

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

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

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

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

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

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

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

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

Implementors

impl<A> AsyncDataSource<A> for AsyncFileDataSource<A>where
    A: Digest + Send,

impl<R, A> AsyncDataSource<A> for AsyncUnseekableDataSource<R, A>where
    R: 'static + AsyncRead + Debug + Unpin + Send + Sync,
    A: Digest,