From 8df1ded873defa7629087658f5496af6a25085f4 Mon Sep 17 00:00:00 2001
From: ybbh <guohua16@outlook.com>
Date: Fri, 5 Apr 2024 11:42:12 +0800
Subject: [PATCH] scupt-net

---
 src/io_service.rs       | 8 ++++++++
 src/io_service_async.rs | 2 ++
 src/io_service_sync.rs  | 2 ++
 3 files changed, 12 insertions(+)

diff --git a/src/io_service.rs b/src/io_service.rs
index ce4642a..80d4c7b 100644
--- a/src/io_service.rs
+++ b/src/io_service.rs
@@ -199,6 +199,10 @@ impl<M: MsgTrait> IOService<M> {
 
 
 impl<M: MsgTrait> IOServiceAsync<M> for IOService<M> {
+    fn local_run(&self, local_set: &LocalSet) {
+        self.run_local(local_set)
+    }
+
     fn block_run(&self, opt: Option<LocalSet>, runtime: Arc<Runtime>) {
         self.run(opt, runtime);
     }
@@ -242,6 +246,10 @@ impl<M: MsgTrait> IOServiceAsync<M> for IOService<M> {
 
 
 impl<M: MsgTrait> IOServiceSync<M> for IOService<M> {
+    fn local_run(&self, local_set: &LocalSet) {
+        self.run_local(local_set)
+    }
+
     fn block_run(&self, opt: Option<LocalSet>, runtime: Arc<Runtime>) {
         self.run(opt, runtime);
     }
diff --git a/src/io_service_async.rs b/src/io_service_async.rs
index 3b3bf75..85b8877 100644
--- a/src/io_service_async.rs
+++ b/src/io_service_async.rs
@@ -11,6 +11,8 @@ use crate::message_receiver_async::{ReceiverAsync, ReceiverRRAsync};
 use crate::message_sender_async::{SenderAsync, SenderRRAsync};
 
 pub trait IOServiceAsync<M: MsgTrait>: Send + Sync {
+    fn local_run(&self, local_set:&LocalSet);
+
     fn block_run(&self, opt: Option<LocalSet>, runtime: Arc<Runtime>);
 
     fn node_id(&self) -> NID;
diff --git a/src/io_service_sync.rs b/src/io_service_sync.rs
index cf8449a..1152aff 100644
--- a/src/io_service_sync.rs
+++ b/src/io_service_sync.rs
@@ -11,6 +11,8 @@ use crate::message_receiver_sync::ReceiverSync;
 use crate::message_sender_sync::SenderSync;
 
 pub trait IOServiceSync<M: MsgTrait>: Send + Sync {
+    fn local_run(&self, local_set:&LocalSet);
+
     fn block_run(&self, opt: Option<LocalSet>, runtime: Arc<Runtime>);
 
     fn node_id(&self) -> NID;