futures ordered: add clear fn

Slixe · Slixe · commit de666608cc2c · 2025-02-25T17:36:19.000+01:00
diff --git a/futures-util/src/stream/futures_ordered.rs b/futures-util/src/stream/futures_ordered.rs
@@ -169,6 +169,14 @@ impl<Fut: Future> FuturesOrdered<Fut> {
         self.next_outgoing_index -= 1;
         self.in_progress_queue.push(wrapped);
     }
+
+    /// Clear the whole `FuturesOrdered` queue.
+    /// 
+    /// This function clears the pending futures and the queued outputs
+    /// to make it fully empty.
+    pub fn clear(&mut self) {
+        *self = Self::new();
+    }
 }
 
 impl<Fut: Future> Default for FuturesOrdered<Fut> {

Original file line number	Diff line number	Diff line change
`@@ -169,6 +169,14 @@ impl<Fut: Future> FuturesOrdered<Fut> {`
`169`	`169`	`self.next_outgoing_index -= 1;`
`170`	`170`	`self.in_progress_queue.push(wrapped);`
`171`	`171`	`}`
	`172`	`+`
	`173`	+ /// Clear the whole `FuturesOrdered` queue.
	`174`	`+ ///`
	`175`	`+ /// This function clears the pending futures and the queued outputs`
	`176`	`+ /// to make it fully empty.`
	`177`	`+ pub fn clear(&mut self) {`
	`178`	`+ *self = Self::new();`
	`179`	`+ }`
`172`	`180`	`}`
`173`	`181`
`174`	`182`	`impl<Fut: Future> Default for FuturesOrdered<Fut> {`