Struct telegram_bot::Api
[−]
[src]
pub struct Api { /* fields omitted */ }
Main type for sending requests to the Telegram bot API.
Methods
impl Api
[src]
fn configure<T: AsRef<str>>(token: T) -> Config
[src]
Start construction of the Api
instance.
Examples
Using default connector.
use telegram_bot::Api; use tokio_core::reactor::Core; let core = Core::new().unwrap(); let api = Api::configure(telegram_token).build(core.handle()).unwrap();
Using custom connector.
use telegram_bot::Api; use telegram_bot::connector::hyper; use tokio_core::reactor::Core; let core = Core::new().unwrap(); let api = Api::configure(telegram_token) .connector(hyper::default_connector(&core.handle()).unwrap()) .build(core.handle()).unwrap();
fn stream(&self) -> UpdatesStream
[src]
Create a stream which produces updates from the Telegram server.
Examples
use futures::Stream; let future = api.stream().for_each(|update| { println!("{:?}", update); Ok(()) });
fn spawn<Req: Request>(&self, request: Req)
[src]
Send a request to the Telegram server and do not wait for a response.
Examples
let chat = ChatId::new(61031); api.spawn(chat.text("Message"))
fn send_timeout<Req: Request>(
&self,
request: Req,
duration: Duration
) -> TelegramFuture<Option<<Req::Response as ResponseType>::Type>>
[src]
&self,
request: Req,
duration: Duration
) -> TelegramFuture<Option<<Req::Response as ResponseType>::Type>>
Send a request to the Telegram server and wait for a response, timing out after duration
.
Future will resolve to None
if timeout fired.
Examples
use std::time::Duration; let future = api.send_timeout(GetMe, Duration::from_secs(5)); future.and_then(|me| Ok(assert!(me.is_some())));
fn send<Req: Request>(
&self,
request: Req
) -> TelegramFuture<<Req::Response as ResponseType>::Type>
[src]
&self,
request: Req
) -> TelegramFuture<<Req::Response as ResponseType>::Type>
Send a request to the Telegram server and wait for a response.
Examples
let future = api.send(GetMe); future.and_then(|me| Ok(println!("{:?}", me)));