Struct rf_distributed::platform::asynchronous::RuFiPlatform

pub struct RuFiPlatform { /* private fields */ }

This struct represents the platform on which the program is executed

Implementations

impl RuFiPlatform

pub fn new( mailbox: Box<dyn Mailbox>, network: Box<dyn Network>, context: Context, discovery: Box<dyn Discovery>, setup: Box<dyn NbrSensorSetup> ) -> Self

Creates a new platform

pub async fn run_forever<P, A>(self, program: P) -> Result<(), Box<dyn Error>>

where P: Fn(RoundVM) -> (RoundVM, A) + Copy, A: Clone + 'static + FromStr + Display,

Runs indefinitely the program on the platform

Arguments

• program - The aggregate program to be executed

Generic Arguments

• P - The type of the aggregate program, it must be a function that takes a RoundVM and returns a RoundVM and a result of type A
• A - The type of the result of the aggregate program