Skip to content

Commit 1978ae1

Browse files
authored
remove unnecessary clones (#224)
Signed-off-by: Dirk Rusche <[email protected]>
1 parent c4a5443 commit 1978ae1

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/binding/http/deserializer.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,10 +34,10 @@ impl<'a, T: Headers<'a>> BinaryDeserializer for Deserializer<'a, T> {
3434
.unwrap()?,
3535
)?;
3636

37-
visitor = visitor.set_spec_version(spec_version.clone())?;
38-
3937
let attributes = spec_version.attribute_names();
4038

39+
visitor = visitor.set_spec_version(spec_version)?;
40+
4141
for (hn, hv) in self.headers.iter().filter(|(hn, _)| {
4242
let key = hn.as_str();
4343
SPEC_VERSION_HEADER.ne(key) && key.starts_with("ce-")

src/binding/rdkafka/kafka_consumer_record.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,10 +51,10 @@ impl BinaryDeserializer for ConsumerRecordDeserializer {
5151
})?,
5252
)?;
5353

54-
visitor = visitor.set_spec_version(spec_version.clone())?;
55-
5654
let attributes = spec_version.attribute_names();
5755

56+
visitor = visitor.set_spec_version(spec_version)?;
57+
5858
if let Some(hv) = self.headers.remove(CONTENT_TYPE) {
5959
visitor = visitor.set_attribute(
6060
"datacontenttype",

0 commit comments

Comments
 (0)