rmanach/deployer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix documentation

Browse Source
This commit is contained in:
rmanach 2023-05-09 09:20:28 +02:00
parent 0683ea3481
commit 3e3a53dbe6
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/worker/worker.rs
View File

@ -68,7 +68,7 @@ impl<H: Handler, N: Notifier> Worker<H, N> {
*guard
}
// launch launches a thread to handle all the `Message` form the `queue`.
// launch launches a thread to handle all the `Message` from the `queue`.
//
// It tries to parse the incoming `Message` into a `Runner` and runs it.
// If an `Unknown` error is returned from the handler, the thread is stopped and its status is set to `Failed`.
@ -156,7 +156,6 @@ impl<H: Handler, N: Notifier> Manager<H, N> {
//
// parameters:
// * `nb_workers`: number of workers to launch
// * `shared_handlers`: a thread-sharable `Handler`
//
// Example:
// deployer.launch_workers::<Job>(5)
@ -176,10 +175,6 @@ impl<H: Handler, N: Notifier> Manager<H, N> {
self.status = ManagerStatus::Up;
}
// pub async fn get_events(&self, end: Shutdown) -> EventStream![] {
// self.notifier.events(end).await
// }
// subscribe subscribes to a `Receiver` channel and notify all the related workers.
pub fn subscribe(&self, receiver: Receiver<Message>) {
let queue = self.queue.clone();