Struct Spawner

pub struct Spawner { /* private fields */ }

The Spawner struct contains the state required to create and cancel jobs

Implementations

impl Spawner

pub fn new(rc: Sender<Event>, listener: Receiver<SpawnerMsg>) -> Self

Create a new Spawner from the Sender half of the receiver channel and the Receiver half of the Spawner channel

pub async fn run(&mut self) -> Result<(), Error>

Run the spawner

When running, the spawner awaits messages on self.rx and if the messages are:

1. SpawnerMsg::Execute - it will create the cancellation channel for this job and run the executor for this job in a new task
2. SpawnerMsg::Cancel - it will broadcast the cancellation message to the appropriate job so that the job is aborted gracefully