fix async stest

commons/stest/src/lib.rs

@@ -3,14 +3,14 @@
 
 //! The stest lib enhances the rust test framework with some useful functions.
 
+use actix::System;
 use anyhow::{format_err, Result};
 use futures::channel::mpsc::{unbounded, UnboundedReceiver, UnboundedSender};
 use futures::stream::StreamExt;
 use futures::Future;
 use std::sync::mpsc::{Receiver, Sender};
 use std::time::Duration;
 pub use stest_macro::test;
-pub use tokio::{runtime::Runtime, task::LocalSet};
 
 pub mod actix_export {
     pub use actix_rt::*;
@@ -59,13 +59,16 @@ where
     F: Future<Output = T> + Send + 'static,
     T: Send + 'static,
 {
-    let t = tokio::task::spawn(f).await;
-    let _ = tx.unbounded_send(t.map_err(Into::<anyhow::Error>::into));
+    let res = System::current().arbiter().spawn(async move {
+        tx.unbounded_send(Ok(f.await)).unwrap();
+    });
+    if !res {
+        panic!("stest default system is died!")
+    }
 }
 
 pub async fn wait_result<T>(mut rx: UnboundedReceiver<Result<T>>) -> T {
     let result = rx.next().await;
-    actix_rt::System::current().stop();
     match result {
         Some(Ok(t)) => t,
         Some(Err(e)) => panic!("test fail: {:?}", e),