OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2024-12-23 06:51:01 +01:00
Code Issues Projects Releases Packages Wiki Activity

Remove Arc from dialogues_repl

Browse source
This commit is contained in:
Temirkhan Myrzamadi 2020-07-31 16:16:14 +06:00
parent 9115622ee3
commit 3e01e0f65f
1 changed files with 3 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/dispatching/repls/dialogues_repl.rs
View file

@ -1,17 +1,15 @@
use crate::{ use crate::{
dispatching::{ dispatching::{
dialogue::{DialogueDispatcher, DialogueStage, DialogueWithCx, GetChatId}, dialogue::{DialogueDispatcher, DialogueStage, DialogueWithCx},
update_listeners, update_listeners,
update_listeners::UpdateListener, update_listeners::UpdateListener,
Dispatcher, DispatcherHandlerRx, DispatcherHandlerRxExt, UpdateWithCx, Dispatcher, UpdateWithCx,
}, },
error_handlers::{LoggingErrorHandler, OnError}, error_handlers::{LoggingErrorHandler, OnError},
types::Message, types::Message,
utils::command::BotCommand,
Bot, Bot,
}; };
use futures::StreamExt; use std::{convert::Infallible, fmt::Debug, future::Future};
use std::{convert::Infallible, fmt::Debug, future::Future, sync::Arc};
/// A [REPL] for dialogues. /// A [REPL] for dialogues.
/// ///
@ -74,8 +72,6 @@ pub async fn dialogues_repl_with_listener<'a, H, D, Fut, L, ListenerE, HandlerE>
Result<DialogueStage<D>, HandlerE>: OnError<HandlerE>, Result<DialogueStage<D>, HandlerE>: OnError<HandlerE>,
HandlerE: Debug + Send, HandlerE: Debug + Send,
{ {
let handler = Arc::new(handler);
Dispatcher::new(bot) Dispatcher::new(bot)
.messages_handler(DialogueDispatcher::new( .messages_handler(DialogueDispatcher::new(
|DialogueWithCx { cx, dialogue }: DialogueWithCx<Message, D, Infallible>| async move { |DialogueWithCx { cx, dialogue }: DialogueWithCx<Message, D, Infallible>| async move {