extern crate futures;
extern crate telegram_bot_fork;
extern crate tokio;
use std::env;
use futures::{future::lazy, Stream};
use telegram_bot_fork::*;
fn main() {
tokio::runtime::current_thread::Runtime::new()
.unwrap()
.block_on(lazy(|| {
let token = env::var("TELEGRAM_BOT_TOKEN").unwrap();
let api = Api::new(token).unwrap();
let stream = api.stream().then(|mb_update| {
let res: Result<Result<Update, Error>, ()> = Ok(mb_update);
res
});
stream.for_each(|mb_update| {
println!("{:?}", mb_update);
Ok(())
})
}))
.unwrap();
}