Skip to content

Commit fa75cc7

Browse files
committed
feat: parse raw msgpack
1 parent d0363c2 commit fa75cc7

3 files changed

Lines changed: 23 additions & 7 deletions

File tree

Cargo.lock

Lines changed: 18 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ edition = "2024"
77
custom_derive = "0.1.7"
88
elasticsearch = "9.0.0-alpha.1"
99
enum_derive = "0.1.7"
10+
msgpack_simple = "1.0.2"
1011
redis = "0.32.4"
1112
rmp = "0.8.14"
1213
rmp-serde = "1.3.0"

src/main.rs

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
extern crate custom_derive;
33
#[macro_use]
44
extern crate enum_derive;
5-
5+
use msgpack_simple::{Extension, MapElement, MsgPack};
66
use std::{collections::HashMap, error::Error, ops::Index};
77

88
use redis::Commands;
@@ -60,12 +60,10 @@ async fn main() -> Result<(), Box<dyn Error>> {
6060
})
6161
.collect::<Result<Vec<Vec<u8>>, Box<dyn Error>>>()?;
6262

63-
let un_mspacked: Vec<rmpv::Value> = un_valued
64-
.iter()
65-
.map(|e| rmpv::Value::from(e.to_owned()))
66-
.collect();
63+
let un_mspacked: Result<Vec<MsgPack>, msgpack_simple::ParseError> =
64+
un_valued.iter().map(|e| MsgPack::parse(e)).collect();
6765

68-
dbg!(un_valued);
66+
dbg!(un_mspacked);
6967

7068
Ok(())
7169
}

0 commit comments

Comments
 (0)