fix: update async-stream to 0.3

Cargo.toml

@@ -12,7 +12,7 @@ nightly = []
 [dependencies]
 anyhow = { default-features = false, version = "1.0" }
 async-std = { default-features = false, features = ["attributes", "std"], version = "1.6" }
-async-stream = { default-features = false, version = "0.2" }
+async-stream = { default-features = false, version = "0.3" }
 async-trait = { default-features = false, version = "0.1" }
 bitswap = { path = "bitswap" }
 byteorder =  { default-features = false, version = "1.3" }

http/Cargo.toml

@@ -10,7 +10,7 @@ prost-build = { default-features = false, version = "0.6" }
 vergen = { default-features = false, version = "3.1" }
 
 [dependencies]
-async-stream = { default-features = false, version = "0.2" }
+async-stream = { default-features = false, version = "0.3" }
 bytes = { default-features = false, version = "0.5" }
 cid = { default-features = false, version = "0.5" }
 futures = { default-features = false, version = "0.3" }
@@ -33,7 +33,7 @@ tar = { default-features = false, version = "0.4" }
 thiserror = { default-features = false, version = "1.0" }
 tokio = { default-features = false, features = ["full"], version = "0.2" }
 tracing = { default-features = false, features = ["log"], version = "0.1" }
-tracing-subscriber = { default-features = false, features = ["fmt", "tracing-log"], version = "0.2" }
+tracing-subscriber = { default-features = false, features = ["fmt", "tracing-log", "env-filter"], version = "0.2" }
 url = { default-features = false, version = "2.1" }
 warp = { default-features = false, version = "0.2" }
 

http/src/lib.rs

@@ -1,6 +1,3 @@
-// Required by the use of async_stream
-#![recursion_limit = "512"]
-
 #[macro_use]
 extern crate tracing;
 

http/src/v0/refs.rs

@@ -472,7 +472,7 @@ fn iplds_refs<T: IpfsTypes>(
                 }
             };
 
-            let mut ipld = match decode_ipld(&cid, &data) {
+            let ipld = match decode_ipld(&cid, &data) {
                 Ok(ipld) => ipld,
                 Err(e) => {
                     warn!("failed to parse {}, linked from {}: {}", cid, source, e);

http/src/v0/root_files.rs

@@ -161,7 +161,7 @@ fn walk<Types: IpfsTypes>(
                 ContinuedWalk::File(segment, item) => {
                     if let Entry::Metadata(MetadataEntry::File(.., p, md, size)) = item.as_entry() {
                         if segment.is_first() {
-                            for mut bytes in tar_helper.apply_file(p, md, size)?.iter_mut() {
+                            for bytes in tar_helper.apply_file(p, md, size)?.iter_mut() {
                                 if let Some(bytes) = bytes.take() {
                                     yield bytes;
                                 }
@@ -194,7 +194,7 @@ fn walk<Types: IpfsTypes>(
                     if let Entry::Metadata(metadata_entry) = item.as_entry() {
                         let metadata = metadata_entry.metadata();
                         let path = metadata_entry.path();
-                        for mut bytes in tar_helper.apply_directory(path, metadata)?.iter_mut() {
+                        for bytes in tar_helper.apply_directory(path, metadata)?.iter_mut() {
                             if let Some(bytes) = bytes.take() {
                                 yield bytes;
                             }
@@ -210,7 +210,7 @@ fn walk<Types: IpfsTypes>(
                         let target = Path::new(target);
                         let metadata = metadata_entry.metadata();
 
-                        for mut bytes in tar_helper.apply_symlink(path, target, metadata)?.iter_mut() {
+                        for bytes in tar_helper.apply_symlink(path, target, metadata)?.iter_mut() {
                             if let Some(bytes) = bytes.take() {
                                 yield bytes;
                             }

src/lib.rs

@@ -1,7 +1,5 @@
 //! IPFS node implementation
 //#![deny(missing_docs)]
-// Recursion limit is required by the use of async_stream
-#![recursion_limit = "512"]
 #![cfg_attr(feature = "nightly", feature(external_doc))]
 #![cfg_attr(feature = "nightly", doc(include = "../README.md"))]