extern crate futures;
extern crate telegram_bot;
extern crate tokio_core;
use std::env;
use futures::Stream;
use tokio_core::reactor::Core;
use telegram_bot::*;
fn main() {
let mut core = Core::new().unwrap();
let token = env::var("TELEGRAM_BOT_TOKEN").unwrap();
let api = Api::configure(token).build(core.handle()).unwrap();
let stream = api.stream().then(|mb_update| {
let res: Result<Result<Update, Error>, ()> = Ok(mb_update);
res
});
let future = stream.for_each(|mb_update| {
println!("{:?}", mb_update);
Ok(())
});
core.run(future).unwrap();
}