change a usage related to ownership
This commit is contained in:
@@ -333,7 +333,7 @@ impl Client {
|
|||||||
/// The core `SUBSCRIBE` logic, used by misc subscribe fns
|
/// The core `SUBSCRIBE` logic, used by misc subscribe fns
|
||||||
async fn subscribe_cmd(&mut self, channels: &[String]) -> crate::Result<()> {
|
async fn subscribe_cmd(&mut self, channels: &[String]) -> crate::Result<()> {
|
||||||
// Convert the `Subscribe` command into a frame
|
// Convert the `Subscribe` command into a frame
|
||||||
let frame = Subscribe::new(&channels).into_frame();
|
let frame = Subscribe::new(channels.to_vec()).into_frame();
|
||||||
|
|
||||||
debug!(request = ?frame);
|
debug!(request = ?frame);
|
||||||
|
|
||||||
|
|||||||
@@ -34,10 +34,8 @@ 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: &[String]) -> Subscribe {
|
pub(crate) fn new(channels: Vec<String>) -> Subscribe {
|
||||||
Subscribe {
|
Subscribe {channels}
|
||||||
channels: channels.to_vec(),
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Parse a `Subscribe` instance from a received frame.
|
/// Parse a `Subscribe` instance from a received frame.
|
||||||
@@ -288,7 +286,7 @@ impl Unsubscribe {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Parse a `Unsubscribe` instance from a received frame.
|
/// Parse an `Unsubscribe` instance from a received frame.
|
||||||
///
|
///
|
||||||
/// The `Parse` argument provides a cursor-like API to read fields from the
|
/// The `Parse` argument provides a cursor-like API to read fields from the
|
||||||
/// `Frame`. At this point, the entire frame has already been received from
|
/// `Frame`. At this point, the entire frame has already been received from
|
||||||
|
|||||||
Reference in New Issue
Block a user