asink

Asynchorous sink wrapper for time-series data

Usage

```rust extern crate asink; extern crate serde;

[macro_use]

extern crate serde_derive;

use asink::*; use std::sync::mpsc::Sender;

/// This will be serialized into msgpack

[derive(Serialize)]

struct Doc { id: usize, data: Vec, }

fn experiment(s: Sender) { for i in 0..5 { let doc = Doc { id: i, data: vec![i as f64], }; s.send(doc).unwrap(); // Send data to sink } }

fn main() { let sink = msgpack::MsgpackSink::from_str("test.msg"); let (s, th) = sink.run(); // Sink start thread to write recieved data into msgpack experiment(s); th.join().unwrap(); } ```