an implementation of changes-stream in Rust.
this code reads in a readable stream from an endpoint and returns each chunk in JSON.
this code works off of the tokio branch of hyper to take advantage of new Rust Futures.
changes-stream-rust only works on nightly because it uses serde.
in your Cargo.toml:
[dependencies]
changes-stream = { git = "https://github.com/ashleygwilliams/changes-stream-rust.git" }from examples/follower.rs:
extern crate changes_stream;
extern crate futures;
use std::io;
use std::io::Write;
use changes_stream::ChangesStream;
fn main() {
let url = "https://replicate.npmjs.com/_changes".to_string();
let mut changes = ChangesStream::new(url);
changes.on(|change| {
io::stdout().write_all(&change).unwrap();
});
changes.run();
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent