Twitter Stream

Rust 库，用于监听 Twitter 流 API。

要求

此库需要 Rust 1.21 或更高版本。

用法

将其添加到您的 Cargo.toml

[dependencies]
twitter-stream = "0.5"

并在您的 crate 根目录下添加此内容

extern crate twitter_stream;

以下是一个基本示例，以 JSON 格式打印公开提及 @Twitter

extern crate futures;
extern crate tokio_core;
extern crate twitter_stream;

use futures::{Future, Stream};
use tokio_core::reactor::Core;
use twitter_stream::{Token, TwitterStreamBuilder};

fn main() {
    let token = Token::new("consumer_key", "consumer_secret", "access_key", "access_secret");

    let mut core = Core::new().unwrap();

    let future = TwitterStreamBuilder::filter(&token).handle(&core.handle())
        .replies(true)
        .track(Some("@Twitter"))
        .listen()
        .flatten_stream()
        .for_each(|json| {
            println!("{}", json);
            Ok(())
        });

    core.run(future).unwrap();
}