Fix typos (#145)
This commit is contained in:
@@ -176,7 +176,7 @@ asynchronous Rust patterns with Tokio.
|
|||||||
Commands or other features should only be added if doing so is useful to
|
Commands or other features should only be added if doing so is useful to
|
||||||
demonstrate a new pattern.
|
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
|
Contributions that only focus on clarifying and improving comments are very
|
||||||
welcome.
|
welcome.
|
||||||
|
|||||||
@@ -147,7 +147,7 @@ impl Set {
|
|||||||
frame.push_bulk(Bytes::from(self.key.into_bytes()));
|
frame.push_bulk(Bytes::from(self.key.into_bytes()));
|
||||||
frame.push_bulk(self.value);
|
frame.push_bulk(self.value);
|
||||||
if let Some(ms) = self.expire {
|
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
|
// 1. SET key value EX seconds
|
||||||
// 2. SET key value PX milliseconds
|
// 2. SET key value PX milliseconds
|
||||||
// We the second option because it allows greater precision and
|
// We the second option because it allows greater precision and
|
||||||
|
|||||||
@@ -245,7 +245,7 @@ async fn handle_command(
|
|||||||
Ok(())
|
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
|
/// 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
|
/// a `&str` since `Bytes::from` can reuse the allocation in the `String`, and
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ use tokio::net::TcpListener;
|
|||||||
use tokio::task::JoinHandle;
|
use tokio::task::JoinHandle;
|
||||||
|
|
||||||
/// A basic "hello world" style test. A server instance is started in a
|
/// 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
|
/// the buffer. Set and get commands are sent to the server. The response is
|
||||||
/// then evaluated.
|
/// then evaluated.
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
|
|||||||
@@ -88,7 +88,7 @@ async fn receive_message_multiple_subscribed_channels() {
|
|||||||
assert_eq!(b"howdy?", &message2.content[..])
|
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
|
/// when unsubscribing to all subscribed channels by submitting an empty vec
|
||||||
#[tokio::test]
|
#[tokio::test]
|
||||||
async fn unsubscribes_from_channels() {
|
async fn unsubscribes_from_channels() {
|
||||||
|
|||||||
Reference in New Issue
Block a user