aboutsummaryrefslogtreecommitdiff
path: root/mingling_cli/src/dispatcher_mgr.rs
diff options
context:
space:
mode:
author魏曹先生 <1992414357@qq.com>2026-04-19 01:27:15 +0800
committer魏曹先生 <1992414357@qq.com>2026-04-19 01:27:15 +0800
commit259ce68e66f160574f60c32b8f7ef0522131c16f (patch)
treefa7c21e9f7d98cec478fc6602defc3204bec7406 /mingling_cli/src/dispatcher_mgr.rs
parentfd534d391cff7c25e25db5a7a9f81ae3620f5b95 (diff)
Remove async from dispatcher parsing functions
Diffstat (limited to 'mingling_cli/src/dispatcher_mgr.rs')
-rw-r--r--mingling_cli/src/dispatcher_mgr.rs6
1 files changed, 3 insertions, 3 deletions
diff --git a/mingling_cli/src/dispatcher_mgr.rs b/mingling_cli/src/dispatcher_mgr.rs
index 483a48c..e024417 100644
--- a/mingling_cli/src/dispatcher_mgr.rs
+++ b/mingling_cli/src/dispatcher_mgr.rs
@@ -11,7 +11,7 @@ dispatcher!("add.dispatcher", AddDispatcherCommand => AddDispatcherEntry);
dispatcher!("remove.dispatcher", RemoveDispatcherCommand => RemoveDispatcherEntry);
#[chain]
-pub async fn parse_add_dispatcher(args: AddDispatcherEntry) -> NextProcess {
+pub fn parse_add_dispatcher(args: AddDispatcherEntry) -> NextProcess {
let picker: Picker<ThisProgram> = Picker::new(args.inner);
let dispatcher_name = picker.pick::<String>(()).unpack_directly().0;
let input = AddDispatcherInput::new(dispatcher_name);
@@ -19,7 +19,7 @@ pub async fn parse_add_dispatcher(args: AddDispatcherEntry) -> NextProcess {
}
#[chain]
-pub async fn parse_remove_dispatcher(args: RemoveDispatcherEntry) -> NextProcess {
+pub fn parse_remove_dispatcher(args: RemoveDispatcherEntry) -> NextProcess {
let picker: Picker<ThisProgram> = Picker::new(args.inner);
let dispatcher_name = picker.pick::<String>(()).unpack_directly().0;
let input = AddDispatcherInput::new(dispatcher_name);
@@ -29,7 +29,7 @@ pub async fn parse_remove_dispatcher(args: RemoveDispatcherEntry) -> NextProcess
pack!(AddDispatcherInput = String);
#[chain]
-pub async fn exec_add_dispatcher(_input: AddDispatcherInput) -> NextProcess {
+pub fn exec_add_dispatcher(_input: AddDispatcherInput) -> NextProcess {
AnyOutput::new(AddDispatcherSuccess::new(())).route_chain()
}