Skip to content

Commit 42c3edd

Browse files
fix: KTable test
1 parent 4e47df8 commit 42c3edd

File tree

4 files changed

+264
-76
lines changed

4 files changed

+264
-76
lines changed

src/base/value.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ impl<'de> Deserialize<'de> for RangeValue {
7171
}
7272

7373
/// Value of key.
74-
#[derive(Debug, Clone, PartialEq, Eq, Hash, PartialOrd, Ord)]
74+
#[derive(Debug, Clone, PartialEq, Eq, Hash, PartialOrd, Ord, Deserialize)]
7575
pub enum KeyValue {
7676
Bytes(Bytes),
7777
Str(Arc<str>),
@@ -340,7 +340,7 @@ impl KeyValue {
340340
}
341341
}
342342

343-
#[derive(Debug, Clone, PartialEq)]
343+
#[derive(Debug, Clone, PartialEq, Deserialize)]
344344
pub enum BasicValue {
345345
Bytes(Bytes),
346346
Str(Arc<str>),
@@ -511,7 +511,7 @@ impl BasicValue {
511511
}
512512
}
513513

514-
#[derive(Debug, Clone, Default, PartialEq)]
514+
#[derive(Debug, Clone, Default, PartialEq, Deserialize)]
515515
pub enum Value<VS = ScopeValue> {
516516
#[default]
517517
Null,
@@ -747,7 +747,7 @@ impl<VS> Value<VS> {
747747
}
748748
}
749749

750-
#[derive(Debug, Clone, PartialEq)]
750+
#[derive(Debug, Clone, PartialEq, Deserialize)]
751751
pub struct FieldValues<VS = ScopeValue> {
752752
pub fields: Vec<Value<VS>>,
753753
}
@@ -821,7 +821,7 @@ where
821821
}
822822
}
823823

824-
#[derive(Debug, Clone, Serialize, PartialEq)]
824+
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
825825
pub struct ScopeValue(pub FieldValues);
826826

827827
impl Deref for ScopeValue {

0 commit comments

Comments
 (0)