From e67f819eb9fd74421ae3597a2bc88b54f5cbcb0e Mon Sep 17 00:00:00 2001
From: Joonas Koivunen <joonas@equilibrium.co>
Date: Wed, 15 Apr 2020 13:51:30 +0300
Subject: [PATCH] fix: remove unwrap from refs-local

kept the return value as a stream. it'll at least save us the trouble of
concatenating all of the values into a big vector.
---
 http/src/v0/refs.rs | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/http/src/v0/refs.rs b/http/src/v0/refs.rs
index bf85f927b..028c14a11 100644
--- a/http/src/v0/refs.rs
+++ b/http/src/v0/refs.rs
@@ -355,7 +355,7 @@ pub fn local<T: IpfsTypes>(
 }
 
 async fn inner_local<T: IpfsTypes>(ipfs: Ipfs<T>) -> Result<impl Reply, Rejection> {
-    let refs: Vec<Result<String, Error>> = ipfs
+    let refs = ipfs
         .refs_local()
         .await
         .map_err(StringError::from)?
@@ -367,14 +367,15 @@ async fn inner_local<T: IpfsTypes>(ipfs: Ipfs<T>) -> Result<impl Reply, Rejectio
         })
         .map(|response| {
             serde_json::to_string(&response)
+                .map(|mut s| {
+                    s.push('\n');
+                    s
+                })
                 .map_err(|e| {
                     eprintln!("error from serde_json: {}", e);
                     HandledErr
                 })
-                .unwrap()
-        })
-        .map(|ref_json| Ok(format!("{}{}", ref_json, "\n")))
-        .collect();
+        });
 
     let stream = stream::iter(refs);
     Ok(warp::reply::Response::new(Body::wrap_stream(stream)))