Struct NewsStream 

pub struct NewsStream { /* private fields */ }

A continuous subscription to one or more RSS/Atom sources.

Polls the configured sources on an interval (5 minutes by default, configurable via NewsStreamBuilder::poll_interval) and yields entries as they’re first seen: an initial batch on subscribe, then only new items on each subsequent poll. Backed by a broadcast channel, so resubscribe supports multiple independent consumers of the same subscription.

Example

use finance_query::streaming::NewsStream;
use finance_query::feeds::FeedSource;
use futures::StreamExt;

let mut stream =
    NewsStream::subscribe([FeedSource::Bloomberg, FeedSource::MarketWatch]).await;

while let Some(entry) = stream.next().await {
    println!("[{}] {}", entry.source, entry.title);
}

Implementations

impl NewsStream

pub async fn subscribe(sources: impl IntoIterator<Item = FeedSource>) -> Self

Subscribe to a continuous stream of new entries from the given sources, polling every 5 minutes. Use NewsStreamBuilder to customize the poll interval.

pub fn resubscribe(&self) -> Self

Create a new receiver for this stream.

Useful when you need multiple consumers of the same news subscription.

pub async fn add_sources(&self, sources: impl IntoIterator<Item = FeedSource>)

Add more sources to the subscription.

Example

use finance_query::streaming::NewsStream;
use finance_query::feeds::FeedSource;

let stream = NewsStream::subscribe([FeedSource::Bloomberg]).await;
stream.add_sources([FeedSource::MarketWatch, FeedSource::WsjMarkets]).await;

pub async fn remove_sources( &self, sources: impl IntoIterator<Item = FeedSource>, )

Remove sources from the subscription (matched by FeedSource::url).

Example

use finance_query::streaming::NewsStream;
use finance_query::feeds::FeedSource;

let stream = NewsStream::subscribe([FeedSource::Bloomberg, FeedSource::MarketWatch]).await;
stream.remove_sources([FeedSource::MarketWatch]).await;

pub async fn close(&self)

Stop polling and close the stream.

Trait Implementations

impl Stream for NewsStream

type Item = FeedEntry

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.