idea for streaming

stream.rs

fn kinesis_pipeline(client: DefaultKinesisClient, stream_name: String, num_puts: usize, puts_size: usize) {
    use futures::sync::mpsc::{ unbounded, UnboundedSender, UnboundedReceiver };
    use futures::{ Sink, Future, Stream };
    use futures::stream::Sender;
    use rusoto_core::reactor::DEFAULT_REACTOR;
    use tokio_core::reactor::Core; 
    
    let client = Arc::new(KinesisClient::simple(Region::UsWest2));
    let data = FauxData::new();
    
    let (tx, rx) = unbounded();

    std::thread::spawn(move ||{
        let core = Core::new();
        let prog = rx.buffer_unordered(50).map_err(Error::from).for_each(|x|{
            info!("got an {:?}", x);
            Ok(())
        });
        core.run(prog);
    });

    for rec in data {
        tx = tx.send(rec).expect("failed to send to channel");
        info!("zip");
    }
}