Struct qiniu_upload_manager::AsyncSeekableSource

pub struct AsyncSeekableSource { /* private fields */ }

Available on crate feature async only.

可异步寻址的数据源

用于表示一个分片，需要传入可异步寻址的数据源，以及分片的起始位置和长度

Implementations

impl AsyncSeekableSource

pub fn new(
    source: impl AsyncRead + AsyncSeek + Debug + Send + Sync + Unpin + 'static,
    offset: u64,
    len: u64
) -> Self

创建可异步寻址的数据源

需要传入可异步寻址的数据源，以及分片的起始位置和长度

Examples found in repository

src/data_source/file.rs (line 164)

        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 AsyncRead for AsyncSeekableSource

fn poll_read(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    buf: &mut [u8]
) -> Poll<IoResult<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    bufs: &mut [IoSliceMut<'_>]
) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl AsyncReset for AsyncSeekableSource

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

异步重置输入流

impl Debug for AsyncSeekableSource

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

Formats the value using the given formatter.