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

fix clippy

Browse source
This commit is contained in:
Maybe Waffle 2021-10-10 15:15:16 +03:00
parent 5ccefb8333
commit f6c4701932
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/dispatching/dialogue/dialogue_dispatcher.rs
View file

@ -156,15 +156,17 @@ where
match this.senders.pin().get(&chat_id) {
// An old dialogue
Some(tx) => {
if tx.send(cx).is_err() {
panic!("We are not dropping a receiver or call .close() on it",);
}
assert!(
tx.send(cx).is_ok(),
"We are not dropping a receiver or call .close() on it"
);
}
None => {
let tx = this.new_tx();
if tx.send(cx).is_err() {
panic!("We are not dropping a receiver or call .close() on it",);
}
assert!(
tx.send(cx).is_ok(),
"We are not dropping a receiver or call .close() on it"
);
this.senders.pin().insert(chat_id, tx);
}
}
@ -271,9 +273,7 @@ mod tests {
let tx = tx.clone();
async move {
if tx.send(update).is_err() {
panic!("tx.send(update) failed");
}
assert!(tx.send(update).is_ok(), "tx.send(update) failed");
}
})
.await;