From 259ce68e66f160574f60c32b8f7ef0522131c16f Mon Sep 17 00:00:00 2001 From: 魏曹先生 <1992414357@qq.com> Date: Sun, 19 Apr 2026 01:27:15 +0800 Subject: Remove async from dispatcher parsing functions --- mingling_cli/src/dispatcher_mgr.rs | 6 +++--- mingling_cli/src/main.rs | 5 ++--- 2 files changed, 5 insertions(+), 6 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 = Picker::new(args.inner); let dispatcher_name = picker.pick::(()).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 = Picker::new(args.inner); let dispatcher_name = picker.pick::(()).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() } diff --git a/mingling_cli/src/main.rs b/mingling_cli/src/main.rs index a0066f4..ec75638 100644 --- a/mingling_cli/src/main.rs +++ b/mingling_cli/src/main.rs @@ -3,14 +3,13 @@ use mingling::{macros::gen_program, setup::BasicProgramSetup}; mod dispatcher_mgr; pub use crate::dispatcher_mgr::*; -#[tokio::main] -async fn main() { +fn main() { let mut program = ThisProgram::new(); program.with_setup(BasicProgramSetup); program.with_dispatcher(CompletionDispatcher); program.with_dispatchers((AddDispatcherCommand, RemoveDispatcherCommand)); - program.exec().await; + program.exec(); } gen_program!(); -- cgit