print_everything/
print_everything.rs

1use telebot::Bot;
2use futures::stream::Stream;
3use std::env;
4use futures::{IntoFuture, Future};
5
6fn main() {
7    // Create the bot
8    let bot = Bot::new(&env::var("TELEGRAM_BOT_KEY").unwrap()).update_interval(200);
9
10    let stream = bot.get_stream(None).for_each(|(_, msg)| {
11        println!("Received: {:#?}", msg);
12
13        Ok(())
14    });
15
16    // enter the main loop
17    tokio::run(stream.into_future().map_err(|_| ()));
18    /*let res = lp.run(stream.for_each(|_| Ok(())).into_future());
19    if let Err(err) = res {
20        eprintln!("Event loop shutdown:");
21        for (i, cause) in err.iter_causes().enumerate() {
22            eprintln!(" => {}: {}", i, cause);
23        }
24    }*/
25}