ichika-macros 0.1.0

A helper library for automatically constructing a thread pool that communicates via message pipes.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use anyhow::Result;
use proc_macro2::TokenStream;
use quote::quote;

use crate::tools::pipe_flatten::ClosureMacrosFlatten;

pub(crate) fn generate_closure(closure: ClosureMacrosFlatten) -> Result<TokenStream> {
    let ClosureMacrosFlatten {
        id,
        arg,
        arg_ty,
        ret_ty,
        body,
        ..
    } = closure;
    let id_raw = quote! { stringify!(#id) };

    // TODO: Support async closures
    Ok(quote! {
      struct #id;

      impl ::ichika::node::ThreadNode for #id {
        type Request = #arg_ty;
        type Response = #ret_ty;

        fn run(#arg: Self::Request) -> ::ichika::Status<Self::Response, ::ichika::anyhow::Error> {
          { #body }.into_status()
        }
      }

      impl ::ichika::node::ThreadNodeEnum for #id {
        fn id() -> &'static str {
          #id_raw
        }
      }
    })
}