Struct telers::dispatcher::Dispatcher

pub struct Dispatcher<Client, Propagator, BackoffType = ExponentialBackoff<SystemClock>> { /* private fields */ }

Dispatcher using to dispatch incoming updates to the main router

Implementations

impl<Client, Propagator, BackoffType> Dispatcher<Client, Propagator, BackoffType>

pub fn new<Cfg, PropagatorService, InitError>( main_router: Propagator, bots: impl IntoIterator<Item = Bot<Client>>, polling_timeout: Option<i64>, backoff: BackoffType, allowed_updates: impl IntoIterator<Item = UpdateType>, ) -> Self

where BackoffType: Backoff, Propagator: ToServiceProvider<Config = Cfg, ServiceProvider = PropagatorService, InitError = InitError>, PropagatorService: PropagateEvent<Client>,

Creates new dispatcher

Arguments

• main_router - Main router, whose service will propagate updates to the other routers and its observers
• bots - Bots that will be used for getting updates and sending requests. All bots use the same dispatcher, but each bot has the own polling process. Polling process gets updates and propagates them to the main propagator.
• polling_timeout - Timeout in seconds for long polling
• backoff - Backoff used for handling server-side errors and network errors (like connection reset or telegram server is down, etc.) and set timeout between requests to telegram server
• allowed_updates - List the types of updates you want your bot to receive. For example, specify UpdateType::Message, UpdateType::EditedChannelPost, UpdateType::CallbackQuery to only receive updates of these types.

impl<Client, Propagator> Dispatcher<Client, Propagator>

where Propagator: Default,

pub fn builder() -> Builder<Client, Propagator>

impl<Client, Propagator, BackoffType> Dispatcher<Client, Propagator, BackoffType>

where Propagator: Default,

pub fn builder_with_backoff( val: BackoffType, ) -> Builder<Client, Propagator, BackoffType>

Trait Implementations

impl<Client, BackoffType, PropagatorService, Propagator, Cfg, InitError> ToServiceProvider for Dispatcher<Client, Propagator, BackoffType>

where Client: Send + Sync + 'static, Propagator: ToServiceProvider<Config = Cfg, ServiceProvider = PropagatorService, InitError = InitError>,

This converts all dependencies to ServiceProvider and creates Arc<Service> that contains converted ServiceProviders.

type Config = Cfg

Service factory configuration

type ServiceProvider = Arc<Service<Client, PropagatorService, BackoffType>>

The provider to which the service will be converted

type InitError = InitError

Errors potentially raised while building a service

fn to_service_provider( self, config: Self::Config, ) -> Result<Self::ServiceProvider, Self::InitError>

Convert the service factory to the service