A Rust library for listening on Twitter Streaming API.
This library requires Rust 1.39.0 or later.
Add this to your Cargo.toml
:
[dependencies]
futures = "0.3"
tokio = { version = "0.2", features = ["macros"] }
twitter-stream = "=0.10.0-alpha.5"
Here is a basic example that prints public mentions to @Twitter in JSON format:
use futures::prelude::*;
use twitter_stream::Token;
#[tokio::main]
async fn main() {
let token = Token::new("consumer_key", "consumer_secret", "access_key", "access_secret");
twitter_stream::Builder::filter(token)
.track(Some("@Twitter"))
.listen()
.try_flatten_stream()
.try_for_each(|json| {
println!("{}", json);
future::ok(())
})
.await
.unwrap();
}