Trait qiniu_upload_manager::AsyncDataSource

pub trait AsyncDataSource<A: Digest>: DynClone + Debug + Sync + Send {
    fn slice(
        &self,
        size: PartSize
    ) -> BoxFuture<'_, IoResult<Option<AsyncDataSourceReader>>>;
    fn reset(&self) -> BoxFuture<'_, IoResult<()>>;
    fn source_key(&self) -> BoxFuture<'_, IoResult<Option<SourceKey<A>>>>;
    fn total_size(&self) -> BoxFuture<'_, IoResult<Option<u64>>>;
}

Available on crate feature async only.

异步数据源接口

提供上传所用的数据源

Required Methods

fn slice(
    &self,
    size: PartSize
) -> BoxFuture<'_, IoResult<Option<AsyncDataSourceReader>>>

异步数据源切片

fn reset(&self) -> BoxFuture<'_, IoResult<()>>

异步重置数据源

fn source_key(&self) -> BoxFuture<'_, IoResult<Option<SourceKey<A>>>>

异步获取数据源 KEY

用于区分不同的数据源

fn total_size(&self) -> BoxFuture<'_, IoResult<Option<u64>>>

异步获取数据源大小

Trait Implementations

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

fn clone(&self) -> Self

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: Digest, T: 'a + AsyncDataSource<A> + ?Sized> AsyncDataSource<A> for &'a Twhere
    &'a T: DynClone + Debug + Sync + Send,

fn slice(
    &self,
    size: PartSize
) -> BoxFuture<'_, IoResult<Option<AsyncDataSourceReader>>>

Available on crate feature async only.

fn reset(&self) -> BoxFuture<'_, IoResult<()>>

Available on crate feature async only.

fn source_key(&self) -> BoxFuture<'_, IoResult<Option<SourceKey<A>>>>

Available on crate feature async only.

fn total_size(&self) -> BoxFuture<'_, IoResult<Option<u64>>>

Available on crate feature async only.

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

fn slice(
    &self,
    size: PartSize
) -> BoxFuture<'_, IoResult<Option<AsyncDataSourceReader>>>

Available on crate feature async only.

fn reset(&self) -> BoxFuture<'_, IoResult<()>>

Available on crate feature async only.

fn source_key(&self) -> BoxFuture<'_, IoResult<Option<SourceKey<A>>>>

Available on crate feature async only.

fn total_size(&self) -> BoxFuture<'_, IoResult<Option<u64>>>

Available on crate feature async only.

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

fn slice(
    &self,
    size: PartSize
) -> BoxFuture<'_, IoResult<Option<AsyncDataSourceReader>>>

Available on crate feature async only.

fn reset(&self) -> BoxFuture<'_, IoResult<()>>

Available on crate feature async only.

fn source_key(&self) -> BoxFuture<'_, IoResult<Option<SourceKey<A>>>>

Available on crate feature async only.

fn total_size(&self) -> BoxFuture<'_, IoResult<Option<u64>>>

Available on crate feature async only.

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

fn slice(
    &self,
    size: PartSize
) -> BoxFuture<'_, IoResult<Option<AsyncDataSourceReader>>>

Available on crate feature async only.

fn reset(&self) -> BoxFuture<'_, IoResult<()>>

Available on crate feature async only.

fn source_key(&self) -> BoxFuture<'_, IoResult<Option<SourceKey<A>>>>

Available on crate feature async only.

fn total_size(&self) -> BoxFuture<'_, IoResult<Option<u64>>>

Available on crate feature async only.

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

fn slice(
    &self,
    size: PartSize
) -> BoxFuture<'_, IoResult<Option<AsyncDataSourceReader>>>

Available on crate feature async only.

fn reset(&self) -> BoxFuture<'_, IoResult<()>>

Available on crate feature async only.

fn source_key(&self) -> BoxFuture<'_, IoResult<Option<SourceKey<A>>>>

Available on crate feature async only.

fn total_size(&self) -> BoxFuture<'_, IoResult<Option<u64>>>

Available on crate feature async only.

Implementors

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

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