Add FallibleTask::is_finished() (#34)

mystenmark · web-flow · commit 230b0a4c842b · 2022-10-04T04:53:50.000+09:00
diff --git a/src/task.rs b/src/task.rs
@@ -513,6 +513,13 @@ impl<T> FallibleTask<T> {
     pub async fn cancel(self) -> Option<T> {
         self.task.cancel().await
     }
+
+    /// Returns `true` if the current task is finished.
+    ///
+    /// Note that in a multithreaded environment, this task can change finish immediately after calling this function.
+    pub fn is_finished(&self) -> bool {
+        self.task.is_finished()
+    }
 }
 
 impl<T> Future for FallibleTask<T> {

Original file line number	Diff line number	Diff line change
`@@ -513,6 +513,13 @@ impl<T> FallibleTask<T> {`
`513`	`513`	`pub async fn cancel(self) -> Option<T> {`
`514`	`514`	`self.task.cancel().await`
`515`	`515`	`}`
	`516`	`+`
	`517`	+ /// Returns `true` if the current task is finished.
	`518`	`+ ///`
	`519`	`+ /// Note that in a multithreaded environment, this task can change finish immediately after calling this function.`
	`520`	`+ pub fn is_finished(&self) -> bool {`
	`521`	`+ self.task.is_finished()`
	`522`	`+ }`
`516`	`523`	`}`
`517`	`524`
`518`	`525`	`impl<T> Future for FallibleTask<T> {`