We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 83979f2 commit 2aad553Copy full SHA for 2aad553
src/store/inflight_activation.rs
@@ -318,7 +318,7 @@ impl InflightActivationStore {
318
/// Once dead-lettered tasks have been added to Kafka those tasks can have their status set to
319
/// complete.
320
pub async fn handle_failed_tasks(&self) -> Result<FailedTasksForwarder, Error> {
321
- let results: Vec<FailedTasksForwarder> = self
+ let results = self
322
.shards
323
.iter()
324
.cloned()
@@ -327,9 +327,7 @@ impl InflightActivationStore {
327
.join_all()
328
.await
329
.into_iter()
330
- .collect::<Result<Vec<_>, _>>()?
331
- .into_iter()
332
- .collect();
+ .collect::<Result<Vec<_>, _>>()?;
333
334
Ok(FailedTasksForwarder {
335
to_discard: results
0 commit comments