Merge adfc646 into 0f2a978

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()
+			}
 		}
 	}()
 

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",

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)
 		}