gsathecat
/
lemmy
mirror of https://github.com/LemmyNet/lemmy.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix clippy

federation-send-parallel
phiresky 2024-05-31 13:10:46 +02:00
parent 1c1018b191
commit 101901b8e0
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
crates/federate/src/send.rs
View File

@ -30,7 +30,7 @@ impl PartialEq for SendSuccessInfo {
/// top /// top
impl PartialOrd for SendSuccessInfo { impl PartialOrd for SendSuccessInfo {
fn partial_cmp(&self, other: &Self) -> Option<std::cmp::Ordering> { fn partial_cmp(&self, other: &Self) -> Option<std::cmp::Ordering> {
other.activity_id.partial_cmp(&self.activity_id) Some(self.cmp(other))
} }
} }
impl Ord for SendSuccessInfo { impl Ord for SendSuccessInfo {

4
crates/federate/src/worker.rs
View File

@ -275,7 +275,9 @@ impl InstanceWorker {
.map(|a| a.activity_id == ActivityId(last_id.0 + 1)) .map(|a| a.activity_id == ActivityId(last_id.0 + 1))
.unwrap_or(false) .unwrap_or(false)
{ {
let next = successfuls.pop().unwrap(); let next = successfuls
.pop()
.context("peek above ensures pop has value")?;
last_id = next.activity_id; last_id = next.activity_id;
self.state.last_successful_id = Some(next.activity_id); self.state.last_successful_id = Some(next.activity_id);
self.state.last_successful_published_time = next.published; self.state.last_successful_published_time = next.published;