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 2022-11-07 21:17:01 +04:00
parent 405cf34f03
commit d9bd9e131f
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
crates/teloxide/src/dispatching/dialogue/storage/rocksdb_storage.rs
View file

@ -72,11 +72,11 @@ where
Box::pin(async move { Box::pin(async move {
let key = chat_id.to_le_bytes(); let key = chat_id.to_le_bytes();
if self.db.get(&key)?.is_none() { if self.db.get(key)?.is_none() {
return Err(RocksDbStorageError::DialogueNotFound); return Err(RocksDbStorageError::DialogueNotFound);
} }
self.db.delete(&key).unwrap(); self.db.delete(key).unwrap();
Ok(()) Ok(())
}) })
@ -92,7 +92,7 @@ where
self.serializer.serialize(&dialogue).map_err(RocksDbStorageError::SerdeError)?; self.serializer.serialize(&dialogue).map_err(RocksDbStorageError::SerdeError)?;
let key = chat_id.to_le_bytes(); let key = chat_id.to_le_bytes();
self.db.put(&key, &d)?; self.db.put(key, &d)?;
Ok(()) Ok(())
}) })
@ -105,7 +105,7 @@ where
Box::pin(async move { Box::pin(async move {
let key = chat_id.to_le_bytes(); let key = chat_id.to_le_bytes();
self.db self.db
.get(&key)? .get(key)?
.map(|d| self.serializer.deserialize(&d).map_err(RocksDbStorageError::SerdeError)) .map(|d| self.serializer.deserialize(&d).map_err(RocksDbStorageError::SerdeError))
.transpose() .transpose()
}) })