diff options
Diffstat (limited to 'core/src/async_util')
-rw-r--r-- | core/src/async_util/task_group.rs | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/core/src/async_util/task_group.rs b/core/src/async_util/task_group.rs index 3de2735..7f05696 100644 --- a/core/src/async_util/task_group.rs +++ b/core/src/async_util/task_group.rs @@ -4,7 +4,7 @@ use async_task::FallibleTask; use super::{executor::global_executor, select, CondWait, Either, Executor}; -/// TaskGroup is a group of spawned tasks. +/// TaskGroup A group that contains spawned tasks. /// /// # Example /// @@ -36,7 +36,7 @@ pub struct TaskGroup<'a> { impl TaskGroup<'static> { /// Creates a new TaskGroup without providing an executor /// - /// This will Spawn a task onto a global executor (single-threaded by default). + /// This will spawn a task onto a global executor (single-threaded by default). pub fn new() -> Self { Self { tasks: Mutex::new(Vec::new()), @@ -129,7 +129,7 @@ pub struct TaskHandler { } impl<'a> TaskHandler { - /// Creates a new task handle + /// Creates a new task handler fn new<T, Fut, CallbackF, CallbackFut>( ex: Executor<'a>, fut: Fut, @@ -146,7 +146,6 @@ impl<'a> TaskHandler { let cancel_flag_c = cancel_flag.clone(); let task = ex .spawn(async move { - //start_signal.signal().await; // Waits for either the stop signal or the task to complete. let result = select(stop_signal.wait(), fut).await; @@ -155,7 +154,7 @@ impl<'a> TaskHandler { Either::Right(res) => TaskResult::Completed(res), }; - // Call the callback with the result. + // Call the callback callback(result).await; cancel_flag_c.signal().await; |