[http_proxy_over_p2p] proxy async.

Simultaneously send request-body while reading response-body when
proxying requests.

License: MIT
Signed-off-by: Chris Boddy <chris@boddy.im>

core/corehttp/proxy.go

@@ -33,7 +33,7 @@ func ProxyOption() ServeOption {
 				handleError(w, msg, err, 500)
 				return
 			}
-
+			//send proxy request and response to client
 			newReverseHttpProxy(parsedRequest, &stream).ServeHTTP(w, request)
 		})
 		return mux, nil
@@ -86,7 +86,18 @@ type roundTripper struct {
 }
 
 func (self *roundTripper) RoundTrip(req *http.Request) (*http.Response, error) {
-	req.Write(*self.stream)
+
+	sendRequest := func() {
+		err := req.Write(*self.stream)
+		if err != nil {
+			(*(self.stream)).Close()
+		}
+		if req.Body != nil {
+			req.Body.Close()
+		}
+	}
+	//send request while reading response
+	go sendRequest()
 	s := bufio.NewReader(*self.stream)
 	return http.ReadResponse(s, req)
 }