docs: fix typos (#109)
This commit is contained in:
@@ -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()
|
||||
|
||||
@@ -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;
|
||||
|
||||
Reference in New Issue
Block a user