Struct CancellableAsyncDecoder 

pub struct CancellableAsyncDecoder<R: AsyncRead + Unpin> { /* private fields */ }

Available on crate features alloc and async-tokio only.

An async streaming decoder with cancellation support.

Implementations

impl<R: AsyncRead + Unpin> CancellableAsyncDecoder<R>

pub fn new(reader: R, token: CancellationToken) -> Self

Create a new cancellable async decoder.

pub async fn read_item<T: Decode>(&mut self) -> Result<Option<T>>

Read the next item, checking for cancellation.

pub async fn read_all<T: Decode>(&mut self) -> Result<Vec<T>>

Read all remaining items.

pub fn progress(&self) -> &StreamingProgress

Get current progress.

pub fn is_finished(&self) -> bool

Check if finished.