refactor(core): remove VersionBytes::into_inner use Into<Vec<u8>> instead
use `Into<Vec<u8>>` to match the `AsRef<[u8]>` api
This commit is contained in:
@@ -436,7 +436,7 @@ where
|
|||||||
|
|
||||||
let clear_text = self
|
let clear_text = self
|
||||||
.cryptor
|
.cryptor
|
||||||
.decrypt(key.key(), state.into_inner())
|
.decrypt(key.key(), state.into())
|
||||||
.await
|
.await
|
||||||
.with_context(|| format!("failed decrypting remote state {}", name))?;
|
.with_context(|| format!("failed decrypting remote state {}", name))?;
|
||||||
|
|
||||||
@@ -500,7 +500,7 @@ where
|
|||||||
data.ensure_versions_phf(&SUPPORTED_VERSIONS)?;
|
data.ensure_versions_phf(&SUPPORTED_VERSIONS)?;
|
||||||
let clear_text = self
|
let clear_text = self
|
||||||
.cryptor
|
.cryptor
|
||||||
.decrypt(key.key(), data.into_inner())
|
.decrypt(key.key(), data.into())
|
||||||
.await
|
.await
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
|
|||||||
@@ -70,7 +70,7 @@ where
|
|||||||
let val = stream::iter(vals)
|
let val = stream::iter(vals)
|
||||||
.map(|vb| {
|
.map(|vb| {
|
||||||
vb.ensure_versions(supported_versions)?;
|
vb.ensure_versions(supported_versions)?;
|
||||||
Ok(vb.into_inner())
|
Ok(vb.into())
|
||||||
})
|
})
|
||||||
.map_ok(|buf| {
|
.map_ok(|buf| {
|
||||||
buf_decode(buf).map(|res| res.context("Custom buffer decode function failed"))
|
buf_decode(buf).map(|res| res.context("Custom buffer decode function failed"))
|
||||||
@@ -104,7 +104,7 @@ where
|
|||||||
let val = stream::iter(vals)
|
let val = stream::iter(vals)
|
||||||
.map(|vb| {
|
.map(|vb| {
|
||||||
vb.ensure_versions_phf(supported_versions)?;
|
vb.ensure_versions_phf(supported_versions)?;
|
||||||
Ok(vb.into_inner())
|
Ok(vb.into())
|
||||||
})
|
})
|
||||||
.map_ok(|buf| {
|
.map_ok(|buf| {
|
||||||
buf_decode(buf).map(|res| res.context("Custom buffer decode function failed"))
|
buf_decode(buf).map(|res| res.context("Custom buffer decode function failed"))
|
||||||
|
|||||||
@@ -73,10 +73,6 @@ impl VersionBytes {
|
|||||||
self.as_version_bytes_ref().ensure_versions_phf(versions)
|
self.as_version_bytes_ref().ensure_versions_phf(versions)
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn into_inner(self) -> Vec<u8> {
|
|
||||||
self.1
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn as_version_bytes_ref(&self) -> VersionBytesRef<'_> {
|
pub fn as_version_bytes_ref(&self) -> VersionBytesRef<'_> {
|
||||||
VersionBytesRef::new(self.version(), self.as_ref())
|
VersionBytesRef::new(self.version(), self.as_ref())
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user