Struct ReqwestTelegram 

pub struct ReqwestTelegram { /* private fields */ }

A Telegram which really talks to the Bot API over HTTP.

Implementations

impl ReqwestTelegram

pub fn new( settings: TelegramSettings, client: Option<Client>, ) -> Result<Self, TelegramError>

Creates a notifier and spawns its background delivery worker.

If client is None, an HTTP client is built from the timeouts in settings. Passing an existing client lets the notifier share the application’s connection pool.

Errors

Returns TelegramError::Http if a client must be built and cannot be.

Panics

Panics if called outside a Tokio runtime, because the delivery worker is spawned during construction.

pub async fn flush(&self, timeout: Duration) -> bool

Waits for every queued message to be delivered, up to timeout.

Call this during shutdown. Without it, whatever is still queued when the process exits is lost — including, typically, the notification about whatever caused the shutdown.

Returns true if the queue drained in time.

pub fn queued(&self) -> usize

How many messages are currently waiting to be delivered.

Trait Implementations

impl Debug for ReqwestTelegram

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Telegram for ReqwestTelegram

fn send(&self, chat_id: ChatId, message: Message)

Queues a message for delivery to a chat.

fn send_text(&self, chat_id: ChatId, text: &str)

Queues an unformatted message.