OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2025-01-10 20:12:25 +01:00
Code Issues Projects Releases Packages Wiki Activity

Fmt

Browse source
This commit is contained in:
Temirkhan Myrzamadi 2019-10-22 17:02:43 +06:00
parent 57d7cc0fe1
commit 61d9dc5c0d
1 changed files with 22 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
src/dispatching/dispatchers/filter/mod.rs
View file

@ -5,7 +5,7 @@ use async_trait::async_trait;
use crate::{
dispatching::{
dispatchers::filter::error_policy::ErrorPolicy, filters::Filter,
handler::Handler, updater::Updater,
handler::Handler, updater::Updater, Dispatcher,
},
types::{CallbackQuery, ChosenInlineResult, Message, Update, UpdateKind},
};
@ -197,22 +197,15 @@ where
match kind {
UpdateKind::Message(mes) => {
self.handle(mes, &self.message_handlers)
.await;
self.handle(mes, &self.message_handlers).await
}
UpdateKind::EditedMessage(mes) => {
self.handle(
mes,
&self.edited_message_handlers,
)
.await;
self.handle(mes, &self.edited_message_handlers)
.await;
}
UpdateKind::ChannelPost(post) => {
self.handle(
post,
&self.channel_post_handlers,
)
.await;
self.handle(post, &self.channel_post_handlers)
.await;
}
UpdateKind::EditedChannelPost(post) => {
self.handle(
@ -222,13 +215,22 @@ where
.await;
}
UpdateKind::InlineQuery(query) => {
self.handle(query, &self.inline_query_handlers).await;
self.handle(query, &self.inline_query_handlers)
.await;
}
UpdateKind::ChosenInlineResult(result) => {
self.handle(result, &self.chosen_inline_result_handlers).await;
self.handle(
result,
&self.chosen_inline_result_handlers,
)
.await;
}
UpdateKind::CallbackQuery(callback) => {
self.handle(callback, &self.callback_query_handlers).await;
self.handle(
callback,
&self.callback_query_handlers,
)
.await;
}
}
}
@ -238,9 +240,9 @@ where
async fn handle<T>(&self, update: T, handlers: &Handlers<'a, T, E>)
where
T: std::fmt::Debug
T: std::fmt::Debug,
{
let handler = handlers.iter().find_map(|e|{
let handler = handlers.iter().find_map(|e| {
let (filter, handler) = e;
if filter.test(&update) {
Some(handler)
@ -248,6 +250,7 @@ where
None
}
});
match handler {
Some(handler) => {
if let Err(err) = handler.handle(update).await {
@ -262,7 +265,7 @@ where
}
#[async_trait(? Send)]
impl<'a, U, E> crate::dispatching::Dispatcher<'a, U> for FilterDispatcher<'a, E>
impl<'a, U, E> Dispatcher<'a, U> for FilterDispatcher<'a, E>
where
E: std::fmt::Debug,
U: Updater + 'a,