Struct telebot::bot::Bot

pub struct Bot {
    pub request: RequestHandle,
    pub handlers: HashMap<String, UnboundedSender<(RequestHandle, Message)>>,
    pub unknown_handler: Option<UnboundedSender<(RequestHandle, Message)>>,
    pub callback_handler: Option<UnboundedSender<(RequestHandle, CallbackQuery)>>,
    pub inline_handler: Option<UnboundedSender<(RequestHandle, InlineQuery)>>,
    // some fields omitted
}

Fields

request: RequestHandle

handlers: HashMap<String, UnboundedSender<(RequestHandle, Message)>>

unknown_handler: Option<UnboundedSender<(RequestHandle, Message)>>

callback_handler: Option<UnboundedSender<(RequestHandle, CallbackQuery)>>

inline_handler: Option<UnboundedSender<(RequestHandle, InlineQuery)>>

Methods

impl Bot

pub fn new(key: &str) -> Bot

pub fn update_interval(self, interval: u64) -> Bot

Sets the update interval to an integer in milliseconds

pub fn timeout(self, timeout: u64) -> Bot

Sets the timeout interval for long polling

pub fn new_cmd(
    &mut self,
    cmd: &str
) -> impl Stream<Item = (RequestHandle, Message), Error = Error>

Creates a new command and returns a stream which will yield a message when the command is send

pub fn unknown_cmd(
    &mut self
) -> impl Stream<Item = (RequestHandle, Message), Error = Error>

Returns a stream which will yield a message when none of previously registered commands matches

pub fn callback(
    &mut self
) -> impl Stream<Item = (RequestHandle, CallbackQuery), Error = Error>

Returns a stream which will yield a received CallbackQuery

pub fn inline(
    &mut self
) -> impl Stream<Item = (RequestHandle, InlineQuery), Error = Error>

Returns a stream which will yield a received CallbackQuery

pub fn resolve_name(&self) -> impl Future<Item = Option<String>, Error = Error>

pub fn process_updates(
    self,
    last_id: Arc<AtomicUsize>
) -> impl Stream<Item = (RequestHandle, Update), Error = Error>

pub fn get_stream(
    self,
    name: Option<String>
) -> impl Stream<Item = (RequestHandle, Update), Error = Error>

The main update loop, the update function is called every update_interval milliseconds When an update is available the last_id will be updated and the message is filtered for commands The message is forwarded to the returned stream if no command was found

pub fn into_future(&self) -> impl Future<Item = (), Error = Error>

pub fn run_with<I>(self, other: I) where
    I: IntoFuture<Error = Error>,
    <I as IntoFuture>::Future: Send + 'static,
    <I as IntoFuture>::Item: Send, 

pub fn run(self)

Trait Implementations

impl Clone for Bot

fn clone(&self) -> Bot

Returns a copy of the value.

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

Performs copy-assignment from source.