diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-06-13 17:22:33 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-06-13 17:22:33 +0200 |
| commit | 9b46caa34baa71e737916705810e18aa26bcc005 (patch) | |
| tree | 10560ceccb5946260178e8bfcdc4fcae75a6fa70 | |
| parent | e3b04e83d7b168323083e9f0abc935e622c3409e (diff) | |
| download | netapp-0.7.0.tar.gz netapp-0.7.0.zip | |
| -rw-r--r-- | Cargo.lock | 6 | ||||
| -rw-r--r-- | Cargo.toml | 4 | ||||
| -rw-r--r-- | src/message.rs | 4 | ||||
| -rw-r--r-- | src/util.rs | 4 |
4 files changed, 8 insertions, 10 deletions
@@ -525,7 +525,7 @@ dependencies = [ [[package]] name = "netapp" -version = "0.6.1" +version = "0.7.0" dependencies = [ "arc-swap", "async-trait", @@ -797,9 +797,9 @@ dependencies = [ [[package]] name = "rmp-serde" -version = "0.15.5" +version = "1.1.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "723ecff9ad04f4ad92fe1c8ca6c20d2196d9286e9c60727c4cb5511629260e9d" +checksum = "c5b13be192e0220b8afb7222aa5813cb62cc269ebb5cac346ca6487681d2913e" dependencies = [ "byteorder", "rmp", @@ -1,6 +1,6 @@ [package] name = "netapp" -version = "0.6.1" +version = "0.7.0" authors = ["Alex Auvolat <alex@adnab.me>"] edition = "2018" license-file = "LICENSE" @@ -27,7 +27,7 @@ tokio-util = { version = "0.7", default-features = false, features = ["compat", tokio-stream = "0.1.7" serde = { version = "1.0", default-features = false, features = ["derive", "rc"] } -rmp-serde = "0.15" +rmp-serde = "1.1" hex = "0.4.3" rand = { version = "0.8" } diff --git a/src/message.rs b/src/message.rs index cd40ea7..b0d255c 100644 --- a/src/message.rs +++ b/src/message.rs @@ -155,7 +155,7 @@ impl<M: Message> Req<M> { } pub(crate) fn from_enc(enc: ReqEnc) -> Result<Self, rmp_serde::decode::Error> { - let msg = rmp_serde::decode::from_read_ref(&enc.msg)?; + let msg = rmp_serde::decode::from_slice(&enc.msg)?; Ok(Req { msg: Arc::new(msg), msg_ser: Some(enc.msg), @@ -316,7 +316,7 @@ impl<M: Message> Resp<M> { } pub(crate) fn from_enc(enc: RespEnc) -> Result<Self, Error> { - let msg = rmp_serde::decode::from_read_ref(&enc.msg)?; + let msg = rmp_serde::decode::from_slice(&enc.msg)?; Ok(Self { _phantom: Default::default(), msg, diff --git a/src/util.rs b/src/util.rs index edf8c49..56230b7 100644 --- a/src/util.rs +++ b/src/util.rs @@ -17,9 +17,7 @@ where T: Serialize + ?Sized, { let mut wr = Vec::with_capacity(128); - let mut se = rmp_serde::Serializer::new(&mut wr) - .with_struct_map() - .with_string_variants(); + let mut se = rmp_serde::Serializer::new(&mut wr).with_struct_map(); val.serialize(&mut se)?; Ok(wr) } |