cloudevents
/
sdk-rust
mirror of https://github.com/cloudevents/sdk-rust.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Minor reformatting 

Signed-off-by: Jim Crossley <jim@crossleys.org>
This commit is contained in:
Jim Crossley 2021-07-14 17:32:43 -04:00
parent ac35535283
commit 13a1af1302
4 changed files with 16 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/binding/actix/headers.rs
View File

@ -1,6 +1,6 @@
macro_rules! str_to_header_value { macro_rules! str_to_header_value {
($header_value:expr) => { ($header_value:expr) => {
HeaderValue::from_str($header_value.to_string().as_str()).map_err(|e| { HeaderValue::from_str(&$header_value.to_string()).map_err(|e| {
crate::message::Error::Other { crate::message::Error::Other {
source: Box::new(e), source: Box::new(e),
} }

23
src/binding/rdkafka/kafka_producer_record.rs
View File

@ -45,36 +45,25 @@ impl Default for MessageRecord {
} }
impl BinarySerializer<MessageRecord> for MessageRecord { impl BinarySerializer<MessageRecord> for MessageRecord {
fn set_spec_version(mut self, spec_version: SpecVersion) -> Result<Self> { fn set_spec_version(mut self, sv: SpecVersion) -> Result<Self> {
self.headers = self.headers.add(SPEC_VERSION_HEADER, spec_version.as_str()); self.headers = self.headers.add(SPEC_VERSION_HEADER, &sv.to_string());
Ok(self) Ok(self)
} }
fn set_attribute(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> { fn set_attribute(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> {
self.headers = self.headers.add( let key = &attribute_header(PREFIX, name);
&attribute_header(PREFIX, name), self.headers = self.headers.add(key, &value.to_string());
// TODO: return Option or Result
// .ok_or(crate::message::Error::UnknownAttribute {
// name: String::from(name),
// })?
&value.to_string(),
);
Ok(self) Ok(self)
} }
fn set_extension(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> { fn set_extension(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> {
self.headers = self let key = &attribute_header(PREFIX, name);
.headers self.headers = self.headers.add(key, &value.to_string());
.add(&attribute_header(PREFIX, name), &value.to_string());
Ok(self) Ok(self)
} }
fn end_with_data(mut self, bytes: Vec<u8>) -> Result<MessageRecord> { fn end_with_data(mut self, bytes: Vec<u8>) -> Result<MessageRecord> {
self.payload = Some(bytes); self.payload = Some(bytes);
Ok(self) Ok(self)
} }

14
src/binding/reqwest/client_request.rs
View File

@ -21,22 +21,20 @@ impl RequestSerializer {
} }
impl BinarySerializer<RequestBuilder> for RequestSerializer { impl BinarySerializer<RequestBuilder> for RequestSerializer {
fn set_spec_version(mut self, spec_version: SpecVersion) -> Result<Self> { fn set_spec_version(mut self, spec_ver: SpecVersion) -> Result<Self> {
self.req = self.req.header(SPEC_VERSION_HEADER, spec_version.as_str()); self.req = self.req.header(SPEC_VERSION_HEADER, spec_ver.to_string());
Ok(self) Ok(self)
} }
fn set_attribute(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> { fn set_attribute(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> {
self.req = self let key = &attribute_header(PREFIX, name);
.req self.req = self.req.header(key, value.to_string());
.header(&attribute_header(PREFIX, name), value.to_string());
Ok(self) Ok(self)
} }
fn set_extension(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> { fn set_extension(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> {
self.req = self let key = &attribute_header(PREFIX, name);
.req self.req = self.req.header(key, value.to_string());
.header(&attribute_header(PREFIX, name), value.to_string());
Ok(self) Ok(self)
} }

6
src/binding/warp/server_response.rs
View File

@ -32,7 +32,7 @@ impl BinarySerializer<Response> for ResponseSerializer {
fn set_spec_version(mut self, spec_version: SpecVersion) -> Result<Self> { fn set_spec_version(mut self, spec_version: SpecVersion) -> Result<Self> {
self.builder = self.builder.header( self.builder = self.builder.header(
SPEC_VERSION_HEADER, SPEC_VERSION_HEADER,
HeaderValue::try_from(spec_version.to_string().as_str()).map_err(|e| { HeaderValue::try_from(spec_version.to_string()).map_err(|e| {
crate::message::Error::Other { crate::message::Error::Other {
source: Box::new(e), source: Box::new(e),
} }
@ -44,7 +44,7 @@ impl BinarySerializer<Response> for ResponseSerializer {
fn set_attribute(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> { fn set_attribute(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> {
self.builder = self.builder.header( self.builder = self.builder.header(
&attribute_header(PREFIX, name), &attribute_header(PREFIX, name),
HeaderValue::try_from(value.to_string().as_str()).map_err(|e| { HeaderValue::try_from(&value.to_string()).map_err(|e| {
crate::message::Error::Other { crate::message::Error::Other {
source: Box::new(e), source: Box::new(e),
} }
@ -56,7 +56,7 @@ impl BinarySerializer<Response> for ResponseSerializer {
fn set_extension(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> { fn set_extension(mut self, name: &str, value: MessageAttributeValue) -> Result<Self> {
self.builder = self.builder.header( self.builder = self.builder.header(
&attribute_header(PREFIX, name), &attribute_header(PREFIX, name),
HeaderValue::try_from(value.to_string().as_str()).map_err(|e| { HeaderValue::try_from(&value.to_string()).map_err(|e| {
crate::message::Error::Other { crate::message::Error::Other {
source: Box::new(e), source: Box::new(e),
} }