rm unnecessary method call
This commit is contained in:
@@ -125,7 +125,7 @@ async fn main() -> mini_redis::Result<()> {
|
|||||||
println!("OK");
|
println!("OK");
|
||||||
}
|
}
|
||||||
Command::Publish { channel, message } => {
|
Command::Publish { channel, message } => {
|
||||||
client.publish(&channel, message.into()).await?;
|
client.publish(&channel, message).await?;
|
||||||
println!("Publish OK");
|
println!("Publish OK");
|
||||||
}
|
}
|
||||||
Command::Subscribe { channels } => {
|
Command::Subscribe { channels } => {
|
||||||
|
|||||||
@@ -35,7 +35,7 @@ type Messages = Pin<Box<dyn Stream<Item = Bytes> + Send>>;
|
|||||||
impl Subscribe {
|
impl Subscribe {
|
||||||
/// Creates a new `Subscribe` command to listen on the specified channels.
|
/// Creates a new `Subscribe` command to listen on the specified channels.
|
||||||
pub(crate) fn new(channels: Vec<String>) -> Subscribe {
|
pub(crate) fn new(channels: Vec<String>) -> Subscribe {
|
||||||
Subscribe {channels}
|
Subscribe { channels }
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Parse a `Subscribe` instance from a received frame.
|
/// Parse a `Subscribe` instance from a received frame.
|
||||||
|
|||||||
Reference in New Issue
Block a user