aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-06-13 17:22:33 +0200
committerAlex Auvolat <alex@adnab.me>2023-06-13 17:29:52 +0200
commit3549f9287bd20f97e7107f587887cec167df7e77 (patch)
treef850f4f9bc78e8e8bb3ed519aa1ea523965cad2a
parent34aade6ce9ccc9789d045fa11bd6bb8af421849e (diff)
downloadnetapp-3549f9287bd20f97e7107f587887cec167df7e77.tar.gz
netapp-3549f9287bd20f97e7107f587887cec167df7e77.zip
update rmp-serde to v1.1v0.5.3
-rw-r--r--Cargo.lock6
-rw-r--r--Cargo.toml4
-rw-r--r--src/message.rs4
-rw-r--r--src/util.rs4
4 files changed, 8 insertions, 10 deletions
diff --git a/Cargo.lock b/Cargo.lock
index bd7248c..80cc232 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -428,7 +428,7 @@ dependencies = [
[[package]]
name = "netapp"
-version = "0.5.2"
+version = "0.5.3"
dependencies = [
"arc-swap",
"async-trait",
@@ -677,9 +677,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",
diff --git a/Cargo.toml b/Cargo.toml
index 1a6e5ea..8a0a794 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
[package]
name = "netapp"
-version = "0.5.2"
+version = "0.5.3"
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.2"
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)
}