Struct telegram_bot_fork::Api

pub struct Api { /* fields omitted */ }

Main type for sending requests to the Telegram bot API.

Methods

impl Api

pub fn new<T: AsRef<str>>(token: T) -> Result<Self, Error>

Start construction of the Api instance.

Examples

Using default connector.

use telegram_bot_fork::Api;

let api = Api::new(telegram_token).unwrap();

Using custom connector.

use telegram_bot_fork::{connector::hyper, Api};

let api = Api::with_connector(telegram_token, hyper::default_connector().unwrap());

pub fn with_connector<T: AsRef<str>>(
    token: T,
    connector: Box<dyn Connector>
) -> Self

pub fn set_url<T: AsRef<str>>(&mut self, url: T) -> &mut Self

pub fn stream(&self) -> UpdatesStream

Create a stream which produces updates from the Telegram server.

Examples

use futures::Stream;

let future = api.stream().for_each(|update| {
    println!("{:?}", update);
    Ok(())
});

pub fn spawn<Req: Request>(&self, request: Req)

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"))

pub fn send_timeout<Req: Request>(
    &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())));

pub fn send<Req: Request>(
    &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)));

Trait Implementations

impl Clone for Api

fn clone(&self) -> Api

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.