diff --git a/actix-server/src/worker.rs b/actix-server/src/worker.rs index 90f057d2..65951345 100644 --- a/actix-server/src/worker.rs +++ b/actix-server/src/worker.rs @@ -125,7 +125,7 @@ impl WorkerAvailability { /// /// Worker accepts Socket objects via unbounded channel and starts stream processing. pub(crate) struct ServerWorker { - // UnboundedReceiver should always the first field. + // UnboundedReceiver should always be the first field. // It must be dropped as soon as ServerWorker dropping. rx: UnboundedReceiver, rx2: UnboundedReceiver, @@ -372,7 +372,7 @@ impl Default for WorkerState { impl Drop for ServerWorker { fn drop(&mut self) { - // Stop Arbiter Self runs on on drop. + // Stop the Arbiter ServerWorker runs on on drop. Arbiter::current().stop(); } }