From c157f5a11fdf143cba452aca514d7dca239eb330 Mon Sep 17 00:00:00 2001
From: John Vandenberg <jayvdb@gmail.com>
Date: Thu, 27 Jun 2024 11:48:20 +0800
Subject: [PATCH] Fix typos

---
 README.md                | 2 +-
 src/cmd/set.rs           | 2 +-
 src/cmd/subscribe.rs     | 2 +-
 tests/buffered_client.rs | 2 +-
 tests/client.rs          | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/README.md b/README.md
index bb3efcb..3e25e05 100644
--- a/README.md
+++ b/README.md
@@ -176,7 +176,7 @@ asynchronous Rust patterns with Tokio.
 Commands or other features should only be added if doing so is useful to
 demonstrate a new pattern.
 
-Contributions should come with extensive comments targetted to new Tokio users.
+Contributions should come with extensive comments targeted to new Tokio users.
 
 Contributions that only focus on clarifying and improving comments are very
 welcome.
diff --git a/src/cmd/set.rs b/src/cmd/set.rs
index eae05d7..0fa02cf 100644
--- a/src/cmd/set.rs
+++ b/src/cmd/set.rs
@@ -147,7 +147,7 @@ impl Set {
         frame.push_bulk(Bytes::from(self.key.into_bytes()));
         frame.push_bulk(self.value);
         if let Some(ms) = self.expire {
-            // Expirations in Redis procotol can be specified in two ways
+            // Expirations in Redis protocol can be specified in two ways
             // 1. SET key value EX seconds
             // 2. SET key value PX milliseconds
             // We the second option because it allows greater precision and
diff --git a/src/cmd/subscribe.rs b/src/cmd/subscribe.rs
index ba13390..e9b1f59 100644
--- a/src/cmd/subscribe.rs
+++ b/src/cmd/subscribe.rs
@@ -245,7 +245,7 @@ async fn handle_command(
     Ok(())
 }
 
-/// Creates the response to a subcribe request.
+/// Creates the response to a subscribe request.
 ///
 /// All of these functions take the `channel_name` as a `String` instead of
 /// a `&str` since `Bytes::from` can reuse the allocation in the `String`, and
diff --git a/tests/buffered_client.rs b/tests/buffered_client.rs
index bb51f59..24761c5 100644
--- a/tests/buffered_client.rs
+++ b/tests/buffered_client.rs
@@ -7,7 +7,7 @@ use tokio::net::TcpListener;
 use tokio::task::JoinHandle;
 
 /// A basic "hello world" style test. A server instance is started in a
-/// background task. A client instance is then established and used to intialize
+/// background task. A client instance is then established and used to initialize
 /// the buffer. Set and get commands are sent to the server. The response is
 /// then evaluated.
 #[tokio::test]
diff --git a/tests/client.rs b/tests/client.rs
index acc5e67..154384d 100644
--- a/tests/client.rs
+++ b/tests/client.rs
@@ -88,7 +88,7 @@ async fn receive_message_multiple_subscribed_channels() {
     assert_eq!(b"howdy?", &message2.content[..])
 }
 
-/// test that a client accurately removes its own subscribed chanel list
+/// test that a client accurately removes its own subscribed channel list
 /// when unsubscribing to all subscribed channels by submitting an empty vec
 #[tokio::test]
 async fn unsubscribes_from_channels() {