2 files changed, 8 insertions, 8 deletions
diff --git a/mingling_cli/src/dispatcher_mgr.rs b/mingling_cli/src/dispatcher_mgr.rs
index e024417..93abd23 100644
--- a/mingling_cli/src/dispatcher_mgr.rs
+++ b/mingling_cli/src/dispatcher_mgr.rs
@@ -15,7 +15,7 @@ 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);
-    input.into()
+    input
 }
 
 #[chain]
@@ -23,7 +23,7 @@ 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);
-    input.into()
+    input
 }
 
 pack!(AddDispatcherInput = String);
diff --git a/mingling_macros/src/chain.rs b/mingling_macros/src/chain.rs
index f2f3e03..fe48b59 100644
--- a/mingling_macros/src/chain.rs
+++ b/mingling_macros/src/chain.rs
@@ -143,7 +143,7 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream {
             {
                 let _ = NextProcess;
                 // Call the original function
-                #fn_name(#prev_param).await
+                #fn_name(#prev_param).await.into()
             }
         }
     } else {
@@ -153,7 +153,7 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream {
             {
                 let _ = NextProcess;
                 // Call the original function
-                #fn_name(#prev_param)
+                #fn_name(#prev_param).into()
             }
         }
     };
@@ -163,7 +163,7 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream {
         quote! {
             #(#fn_attrs)*
             #vis async fn #fn_name(#prev_param: #previous_type)
-                -> ::mingling::ChainProcess<#group_name>
+                -> impl Into<::mingling::ChainProcess<#group_name>>
             {
                 #fn_body
             }
@@ -172,7 +172,7 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream {
         quote! {
             #(#fn_attrs)*
             #vis fn #fn_name(#prev_param: #previous_type)
-                -> ::mingling::ChainProcess<#group_name>
+                -> impl Into<::mingling::ChainProcess<#group_name>>
             {
                 #fn_body
             }
@@ -186,7 +186,7 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream {
         {
             let _ = NextProcess;
             // Call the original function
-            #fn_name(#prev_param)
+            #fn_name(#prev_param).into()
         }
     };
 
@@ -194,7 +194,7 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream {
     let origin_proc_fn = quote! {
         #(#fn_attrs)*
         #vis fn #fn_name(#prev_param: #previous_type)
-            -> ::mingling::ChainProcess<#group_name>
+            -> impl Into<::mingling::ChainProcess<#group_name>>
         {
             #fn_body
         }