mirror of
https://github.com/teloxide/teloxide.git
synced 2024-12-22 22:46:39 +01:00
Fmt
This commit is contained in:
parent
8b1c3b8101
commit
8826263e58
1 changed files with 5 additions and 4 deletions
|
@ -12,10 +12,11 @@
|
|||
//! 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;
|
||||
//! UnboundedReceiverStream::new(rx)
|
||||
//! .for_each_concurrent(None, |message| async move {
|
||||
//! dbg!(message.update);
|
||||
//! })
|
||||
//! .await;
|
||||
//! }
|
||||
//! ```
|
||||
//!
|
||||
|
|
Loading…
Reference in a new issue