Forget TaskHandles instead of dropping

dropping the handle aborts the task

src/executor.rs

@@ -14,7 +14,9 @@ impl<T: Future<Output = ()> + Send> Task for T {}
 pub trait TaskExecutor {
     fn spawn(&self, future: Pin<Box<dyn Task>>) -> Result<Box<dyn TaskExec<()>>, Box<dyn Error>>;
 }
-pub trait TaskExec<T: Send>: Future<Output = Result<T, Box<dyn Error>>> + Unpin + Send + Sync {
+pub trait TaskExec<T: Send>:
+    Future<Output = Result<T, Box<dyn Error>>> + Unpin + Send + Sync
+{
     fn abort(self: Box<Self>);
     fn forget(self: Box<Self>);
 }
@@ -65,7 +67,10 @@ mod executor_impl {
     use super::*;
     pub struct TokioExecutor(pub tokio::runtime::Handle);
     impl TaskExecutor for TokioExecutor {
-        fn spawn(&self, future: Pin<Box<dyn Task>>) -> Result<Box<dyn TaskExec<()>>, Box<dyn Error>> {
+        fn spawn(
+            &self,
+            future: Pin<Box<dyn Task>>,
+        ) -> Result<Box<dyn TaskExec<()>>, Box<dyn Error>> {
             Ok(Box::new(TokioJoinHandle(self.0.spawn(future))))
         }
     }
@@ -104,7 +109,10 @@ mod executor_impl {
     }
     pub struct FuturesExecutor(pub futures::executor::ThreadPool);
     impl TaskExecutor for FuturesExecutor {
-        fn spawn(&self, future: Pin<Box<dyn Task>>) -> Result<Box<dyn TaskExec<()>>, Box<dyn Error>> {
+        fn spawn(
+            &self,
+            future: Pin<Box<dyn Task>>,
+        ) -> Result<Box<dyn TaskExec<()>>, Box<dyn Error>> {
             self.0
                 .spawn_with_handle(future)
                 .map(|h| Box::new(FuturesJoinHandle(h)) as Box<dyn TaskExec<()>>)

src/kernel/kernel_ref.rs

@@ -38,7 +38,9 @@ impl KernelRef {
         let mut tx = self.tx.clone();
         sys.run(async move {
             drop(tx.send(msg).await);
-        }).unwrap().forget();
+        })
+        .unwrap()
+        .forget();
     }
 }