From 3e3a53dbe6681702ae9b0a8142cbda67e9d437c6 Mon Sep 17 00:00:00 2001
From: rmanach <romain.manach@intercloud.com>
Date: Tue, 9 May 2023 09:20:28 +0200
Subject: [PATCH] fix documentation

---
 src/worker/worker.rs | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/src/worker/worker.rs b/src/worker/worker.rs
index 7bc3c9e..4b06c10 100644
--- a/src/worker/worker.rs
+++ b/src/worker/worker.rs
@@ -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();