Struct qiniu_upload_manager::AsyncUnseekableDataSource

pub struct AsyncUnseekableDataSource<R: AsyncRead + Debug + Unpin + Send + Sync + 'static + ?Sized, A: Digest = Sha1>(_);

不可寻址的异步数据源

基于一个不可寻址的异步阅读器实现了异步数据源接口

Implementations

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

pub fn new(reader: R) -> Self

创建不可寻址的异步数据源

Examples found in repository

src/scheduler/mod.rs (line 78)

    fn async_upload_reader<R: AsyncRead + Unpin + Debug + Send + Sync + 'static>(
        &self,
        reader: R,
        params: ObjectParams,
    ) -> BoxFuture<ApiResult<Value>> {
        Box::pin(async move {
            self.async_upload(Box::new(AsyncUnseekableDataSource::new(reader)), params)
                .await
        })
    }

src/data_source/file.rs (line 171)

        async fn get_async_seekable_source(&self) -> IoResult<&AsyncSource<A>> {
            self.source
                .get_or_try_init(async {
                    let mut file = AsyncFile::open(&self.path).await?;
                    if let Ok(offset) = file.stream_position().await {
                        Ok(AsyncSource::Seekable {
                            original_offset: offset,
                            file_size: file.metadata().await?.len(),
                            source: AsyncSeekableSource::new(file, 0, 0),
                            current: AsyncMutex::new(SourceOffset {
                                offset,
                                part_number: first_part_number(),
                            }),
                        })
                    } else {
                        Ok(AsyncSource::Unseekable(AsyncUnseekableDataSource::new(file)))
                    }
                })
                .await
        }

Trait Implementations

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

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.

异步获取数据源 KEY

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

Available on crate feature async only.

异步获取数据源大小

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

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

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

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.