Struct ebml_iterable::TagIteratorAsync

pub struct TagIteratorAsync<R: AsyncRead + Unpin, TSpec>where
    TSpec: EbmlSpecification<TSpec> + EbmlTag<TSpec> + Clone,{ /* private fields */ }

This Can be transformed into a [Stream] using into_stream, or consumed directly by calling [.next().await] in a loop.

The struct can be created with the new() function on any source that implements the [futures::AsyncRead] trait.

Implementations

impl<R: AsyncRead + Unpin, TSpec> TagIteratorAsync<R, TSpec>where
    TSpec: EbmlSpecification<TSpec> + EbmlTag<TSpec> + Clone,

pub fn new(read: R) -> Self

pub async fn next(&mut self) -> Option<Result<TSpec, TagIteratorError>>

can be consumed

Examples found in repository

src/tag_iterator_async.rs (line 191)

    pub fn into_stream(self) -> impl Stream<Item=Result<TSpec, TagIteratorError>> {
        futures::stream::unfold(self, |mut read| async {
            let next = read.next().await;
            next.map(move |it| (it, read))
        })
    }

pub fn into_stream(self) -> impl Stream<Item = Result<TSpec, TagIteratorError>>