Struct extrablatt::extrablatt::ArticleStream

#[must_use = "streams do nothing unless polled"]pub struct ArticleStream<TExtractor: Extractor> { /* fields omitted */ }

Stream for getting a Article each at a time.

Implementations

impl ArticleStream<DefaultExtractor>

pub async fn new<T: IntoUrl>(url: T) -> Result<ArticleStream<DefaultExtractor>>

Fetch all article urls from the page the url points to and return a new stream of articles using the crate::DefaultExtractor.

Example

Create a new crate::ArticleStream that yields all articles referenced on https:://example.com/some/path

let mut stream = ArticleStream::new("https:://example.com/some/path").await?;
    while let Some(article) = stream.next().await {
        // ...
    }

impl<TExtractor: Extractor + Unpin> ArticleStream<TExtractor>

pub async fn new_with_extractor<T: IntoUrl>(
    url: T,
    extractor: TExtractor
) -> Result<ArticleStream<TExtractor>>

Fetch all article urls from the page the url points to and return a new stream of articles using a designated crate::Extractor.

Trait Implementations

impl<TExtractor: Extractor + Unpin> Stream for ArticleStream<TExtractor>

type Item = Result<Article, ExtrablattError>

Values yielded by the stream.

fn poll_next(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>
) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.