Trait tokio::io::AsyncSeek

pub trait AsyncSeek {
    fn start_seek(self: Pin<&mut Self>, position: SeekFrom) -> Result<()>;
    fn poll_complete(
        self: Pin<&mut Self>, 
        cx: &mut Context<'_>
    ) -> Poll<Result<u64>>;
}

Seek bytes asynchronously.

This trait is analogous to the std::io::Seek trait, but integrates with the asynchronous task system. In particular, the start_seek method, unlike Seek::seek, will not block the calling thread.

Utilities for working with AsyncSeek values are provided by AsyncSeekExt.

Required methods

fn start_seek(self: Pin<&mut Self>, position: SeekFrom) -> Result<()>

Attempts to seek to an offset, in bytes, in a stream.

A seek beyond the end of a stream is allowed, but behavior is defined by the implementation.

If this function returns successfully, then the job has been submitted. To find out when it completes, call poll_complete.

Errors

This function can return io::ErrorKind::Other in case there is another seek in progress. To avoid this, it is advisable that any call to start_seek is preceded by a call to poll_complete to ensure all pending seeks have completed.

fn poll_complete(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<u64>>

Waits for a seek operation to complete.

If the seek operation completed successfully, this method returns the new position from the start of the stream. That position can be used later with SeekFrom::Start. Repeatedly calling this function without calling start_seek might return the same result.

Errors

Seeking to a negative offset is considered an error.

Loading content...

Implementations on Foreign Types

impl<T: ?Sized + AsyncSeek + Unpin> AsyncSeek for Box<T>

fn start_seek(self: Pin<&mut Self>, pos: SeekFrom) -> Result<()>

fn poll_complete(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<u64>>

impl<T: ?Sized + AsyncSeek + Unpin> AsyncSeek for &mut T

fn start_seek(self: Pin<&mut Self>, pos: SeekFrom) -> Result<()>

fn poll_complete(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<u64>>

impl<P> AsyncSeek for Pin<P> where
    P: DerefMut + Unpin,
    P::Target: AsyncSeek, 

fn start_seek(self: Pin<&mut Self>, pos: SeekFrom) -> Result<()>

fn poll_complete(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<u64>>

impl<T: AsRef<[u8]> + Unpin> AsyncSeek for Cursor<T>

fn start_seek(self: Pin<&mut Self>, pos: SeekFrom) -> Result<()>

fn poll_complete(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Result<u64>>

Loading content...

Implementors

impl AsyncSeek for File

This is supported on crate feature fs only.

fn start_seek(self: Pin<&mut Self>, pos: SeekFrom) -> Result<()>

fn poll_complete(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<u64>>

impl<R: AsyncRead + AsyncSeek> AsyncSeek for BufReader<R>

This is supported on crate feature io-util only.

Seek to an offset, in bytes, in the underlying reader.

The position used for seeking with SeekFrom::Current(_) is the position the underlying reader would be at if the BufReader had no internal buffer.

Seeking always discards the internal buffer, even if the seek position would otherwise fall within it. This guarantees that calling .into_inner() immediately after a seek yields the underlying reader at the same position.

See AsyncSeek for more details.

Note: In the edge case where you’re seeking with SeekFrom::Current(n) where n minus the internal buffer length overflows an i64, two seeks will be performed instead of one. If the second seek returns Err, the underlying reader will be left at the same position it would have if you called seek with SeekFrom::Current(0).

fn start_seek(self: Pin<&mut Self>, pos: SeekFrom) -> Result<()>

fn poll_complete(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<u64>>

impl<W: AsyncWrite + AsyncSeek> AsyncSeek for BufWriter<W>

This is supported on crate feature io-util only.

Seek to the offset, in bytes, in the underlying writer.

Seeking always writes out the internal buffer before seeking.

fn start_seek(self: Pin<&mut Self>, pos: SeekFrom) -> Result<()>

fn poll_complete(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Result<u64>>

Loading content...