diff --git a/api/rest/restapi.go b/api/rest/restapi.go
index 8db74c251..83ff4a1bb 100644
--- a/api/rest/restapi.go
+++ b/api/rest/restapi.go
@@ -531,11 +531,16 @@ func (api *API) addHandler(w http.ResponseWriter, r *http.Request) {
 	wg.Add(1)
 	go func() {
 		defer wg.Done()
+
+		flusher, canFlush := w.(http.Flusher)
 		for v := range output {
 			err := enc.Encode(v)
 			if err != nil {
 				logger.Error(err)
 			}
+			if canFlush {
+				flusher.Flush()
+			}
 		}
 	}()
 
diff --git a/package.json b/package.json
index a0a3bdf4b..6565c226d 100644
--- a/package.json
+++ b/package.json
@@ -69,9 +69,9 @@
     },
     {
       "author": "hsanjuan",
-      "hash": "QmSMWoH8wKuViGUe2ZDr3kDijbzkk81nY71zV1ApibFLxF",
+      "hash": "QmeyKL7WDSPhnhozCB3oC51j5pDs7DnCGWPyVaxgwpncA6",
       "name": "go-libp2p-http",
-      "version": "1.0.8"
+      "version": "1.1.0"
     },
     {
       "author": "ipfs",
diff --git a/peer_manager_test.go b/peer_manager_test.go
index 2efc89dae..f92bb46cc 100644
--- a/peer_manager_test.go
+++ b/peer_manager_test.go
@@ -535,7 +535,7 @@ func TestClustersPeerRejoin(t *testing.T) {
 
 	// add all clusters
 	for i := 1; i < len(clusters); i++ {
-		_, err := clusters[0].PeerAdd(clusters[i].id)
+		err := clusters[i].Join(clusterAddr(clusters[0]))
 		if err != nil {
 			t.Fatal(err)
 		}