diff --git a/src/server.rs b/src/server.rs index 2868b26..37bacfd 100644 --- a/src/server.rs +++ b/src/server.rs @@ -227,7 +227,7 @@ impl Listener { // to the semaphore. // // `acquire_owned()` returns `Err` when the semaphore has been - // closed. We don't ever close the sempahore, so `unwrap()` is safe. + // closed. We don't ever close the semaphore, so `unwrap()` is safe. let permit = self .limit_connections .clone() diff --git a/tests/client.rs b/tests/client.rs index e2e7b42..2d5208d 100644 --- a/tests/client.rs +++ b/tests/client.rs @@ -67,7 +67,7 @@ async fn receive_message_multiple_subscribed_channels() { } /// test that a client accurately removes its own subscribed chanel list -/// when unbscribing to all subscribed channels by submitting an empty vec +/// when unsubscribing to all subscribed channels by submitting an empty vec #[tokio::test] async fn unsubscribes_from_channels() { let (addr, _) = start_server().await;