-
reddit_sse_stream
A Server Side Event stream to deliver Reddit comments and submissions in near real-time to a client.
-
InfluxDB
Power Real-Time Data Analytics at Scale. Get real-time insights from all types of time series data with InfluxDB. Ingest, query, and analyze billions of data points in real-time with unbounded cardinality.
use std::io::{Error, ErrorKind}; use futures::prelude::*; #[tokio::main] async fn main() { let url = "http://stream.pushshift.io"; let stream = reqwest::get(url) .await .unwrap() .bytes_stream(); let mut reader = async_sse::decode( stream .map_err(|e| Error::new(ErrorKind::Other, e)) .into_async_read() ); let event = reader.next().await.unwrap(); println!("{:?}", event); }