chore(kad): update changelog for PR and other cleanup.

examples/distributed-key-value-store/Cargo.toml

@@ -9,6 +9,7 @@ license = "MIT"
 release = false
 
 [dependencies]
+bytes = "1.5"
 async-std = { version = "1.12", features = ["attributes"] }
 async-trait = "0.1"
 futures = { workspace = true }

examples/distributed-key-value-store/src/main.rs

@@ -21,8 +21,8 @@
 #![doc = include_str!("../README.md")]
 
 use async_std::io;
+use bytes::Bytes;
 use futures::{prelude::*, select};
-use libp2p::bytes::Bytes;
 use libp2p::kad;
 use libp2p::kad::store::MemoryStore;
 use libp2p::kad::Mode;
@@ -187,7 +187,7 @@ fn handle_input_line(kademlia: &mut kad::Behaviour<MemoryStore>, line: String) {
             };
             let value = {
                 match args.next() {
-                    Some(value) => Bytes::from(value.as_bytes().to_owned()),
+                    Some(value) => Bytes::copy_from_slice(value.as_bytes()),
                     None => {
                         eprintln!("Expected value");
                         return;

protocols/kad/src/behaviour/test.rs

@@ -1174,8 +1174,8 @@ fn disjoint_query_does_not_finish_before_all_paths_did() {
         Multihash::<64>::wrap(SHA_256_MH, &thread_rng().gen::<[u8; 32]>())
             .expect("32 array to fit into 64 byte multihash"),
     );
-    let record_bob = Record::new(key.clone(), Bytes::from(b"bob".to_vec()));
-    let record_trudy = Record::new(key.clone(), Bytes::from(b"trudy".to_vec()));
+    let record_bob = Record::new(key.clone(), Bytes::copy_from_slice(b"bob"));
+    let record_trudy = Record::new(key.clone(), Bytes::copy_from_slice(b"trudy"));
 
     // Make `bob` and `trudy` aware of their version of the record searched by
     // `alice`.