Macro rustfbp::agent

macro_rules! agent {
    (
        $( input($( $input_name:ident: $input_contract:ident ),*), )*
        $( inarr($( $input_a_name:ident: $input_a_contract:ident ),*), )*
        $( output($( $output_name:ident: $output_contract:ident ),*), )*
        $( outarr($( $output_a_name:ident: $output_a_contract:ident ),*), )*
        $( portal( $portal_type:ty => $portal_value:expr ), )*
        $( option($option:ident), )*
        $( accumulator($acc:ident ), )*
        fn run(&mut $arg:ident) -> Result<Signal> $fun:block
    ) => { ... };
}

The agent macro.

It helps to define a agent, by defining the input and output ports, if there is an option or an acc port, ...

Example :

agent! {
   inputs(input: any),
   outputs(output: any),
   option(generic_text),
   fn run(&mut self) -> Result<Signal> {
       // Receive an IP
       let msg = try!(self.input.input.recv());

       // Received an IP from the option port (a generic_text)
       let opt = self.recv_opt();

       // Get the capn'p reader
       let reader: generic_text::Reader = try!(opt.read_schema());
       // Print the option
       println!("{}", try!(reader.get_text()));

       // Send the received IP outside, but don't care about the success (drop on fail)
       let _ = self.output.output.send(msg);

       Ok(End)
   }
}