Struct Worker 

pub struct Worker<S>
where
    S: State,
{ /* private fields */ }

Runs crate::Jobs.

Implementations

impl<S> Worker<S>

where S: State,

pub fn new(job: Job<S>, state: S) -> Worker<S>

Create a new worker.

pub async fn run(&mut self) -> Result<(), &'static str>

Start running the job.

Errors

If the worker has already started working.

pub async fn stop(&mut self)

Stop the worker. All currently running nodes will be aborted.

pub async fn get_output(&mut self) -> Result<Output, &'static str>

Wait for the worker to finish and return the Output.

Errors

If the worker is not yet running.

pub async fn data(&self) -> HashMap<String, Value>

Return the data collected from running the job.

pub async fn status(&self) -> HashMap<&'static str, NodeState>

Trait Implementations

impl<S> Clone for Worker<S>

where S: Clone + State,

fn clone(&self) -> Worker<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.