diff --git a/crdt-enc/src/lib.rs b/crdt-enc/src/lib.rs index 487503e..ce03f59 100644 --- a/crdt-enc/src/lib.rs +++ b/crdt-enc/src/lib.rs @@ -436,7 +436,7 @@ where let clear_text = self .cryptor - .decrypt(key.key(), state.into_inner()) + .decrypt(key.key(), state.into()) .await .with_context(|| format!("failed decrypting remote state {}", name))?; @@ -500,7 +500,7 @@ where data.ensure_versions_phf(&SUPPORTED_VERSIONS)?; let clear_text = self .cryptor - .decrypt(key.key(), data.into_inner()) + .decrypt(key.key(), data.into()) .await .unwrap(); diff --git a/crdt-enc/src/utils.rs b/crdt-enc/src/utils.rs index e1b6107..a800020 100644 --- a/crdt-enc/src/utils.rs +++ b/crdt-enc/src/utils.rs @@ -70,7 +70,7 @@ where let val = stream::iter(vals) .map(|vb| { vb.ensure_versions(supported_versions)?; - Ok(vb.into_inner()) + Ok(vb.into()) }) .map_ok(|buf| { buf_decode(buf).map(|res| res.context("Custom buffer decode function failed")) @@ -104,7 +104,7 @@ where let val = stream::iter(vals) .map(|vb| { vb.ensure_versions_phf(supported_versions)?; - Ok(vb.into_inner()) + Ok(vb.into()) }) .map_ok(|buf| { buf_decode(buf).map(|res| res.context("Custom buffer decode function failed")) diff --git a/crdt-enc/src/utils/version_bytes.rs b/crdt-enc/src/utils/version_bytes.rs index 91e6265..de4b7ac 100644 --- a/crdt-enc/src/utils/version_bytes.rs +++ b/crdt-enc/src/utils/version_bytes.rs @@ -73,10 +73,6 @@ impl VersionBytes { self.as_version_bytes_ref().ensure_versions_phf(versions) } - pub fn into_inner(self) -> Vec { - self.1 - } - pub fn as_version_bytes_ref(&self) -> VersionBytesRef<'_> { VersionBytesRef::new(self.version(), self.as_ref()) }