diff options
Diffstat (limited to 'mingling_macros/src/chain.rs')
| -rw-r--r-- | mingling_macros/src/chain.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/mingling_macros/src/chain.rs b/mingling_macros/src/chain.rs index f8b1e1c..7b519a1 100644 --- a/mingling_macros/src/chain.rs +++ b/mingling_macros/src/chain.rs @@ -93,11 +93,11 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream { Err(e) => return e.to_compile_error().into(), }; - // Ensure the return type is named "GroupProcess" - if return_type.path.segments.last().unwrap().ident != "GroupProcess" { + // Ensure the return type is named "NextProcess" + if return_type.path.segments.last().unwrap().ident != "NextProcess" { return syn::Error::new( return_type.span(), - "Return type must be 'mingling::marker::GroupProcess'", + "Return type must be 'mingling::marker::NextProcess'", ) .to_compile_error() .into(); @@ -134,7 +134,7 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream { async fn proc(#prev_param: Self::Previous) -> ::mingling::ChainProcess<DefaultProgram> { - let _ = GroupProcess; + let _ = NextProcess; // Call the original function #fn_name(#prev_param).await } @@ -159,7 +159,7 @@ pub fn chain_attr(attr: TokenStream, item: TokenStream) -> TokenStream { async fn proc(#prev_param: Self::Previous) -> ::mingling::ChainProcess<#group_name> { - let _ = GroupProcess; + let _ = NextProcess; // Call the original function #fn_name(#prev_param).await } |