Module teloxide::dispatching[−][src]

Expand description

Updates dispatching.

The key type here is Dispatcher. It encapsulates Bot and handlers for all the update kinds.

Every handler accept tokio::sync::mpsc::UnboundedReceiver (the RX halve of an asynchronous channel). Inside a body of your handler, you typically asynchronously concurrently iterate through updates like this:

use teloxide::prelude::*;
use tokio_stream::wrappers::UnboundedReceiverStream;

async fn handle_messages(rx: DispatcherHandlerRx<AutoSend<Bot>, Message>) {
    UnboundedReceiverStream::new(rx)
        .for_each_concurrent(None, |message| async move {
            dbg!(message.update);
        })
        .await;
}

When Update is received from Telegram, Dispatcher pushes it into an appropriate handler, depending on its kind. That’s simple!

Note that handlers must implement DispatcherHandler, which means that:

You are able to supply DialogueDispatcher as a handler.
You are able to supply functions that accept tokio::sync::mpsc::UnboundedReceiver and return Future<Output = ()> as a handler.

Since they implement DispatcherHandler too.

See the examples.