Struct marid::Composer [] [src]

pub struct Composer<R> {
    // some fields omitted
}

The Composer type.

The Composer will start each runner inside of its own thread when the run() function is called. The current behavior is an ordered setup/run, but in the future a parallel startup mode will be offered.

Methods

impl<R> Composer<R>

fn new(runners: Vec<R>, error_signal: Signal) -> Composer<R>

Creates a new Composer.

The error_signal is the Signal that the Composer will send to runners when another runner in the group has finished with an error.

Trait Implementations

impl Runner for Composer<Box<Runner + Send>>

fn run(self: Box<Self>, signals: Receiver<Signal>) -> Result<(), MaridError>

fn setup(&mut self) -> Result<(), MaridError>