|
@@ -110,7 +110,7 @@ func (p *reverseProxy) ServeHTTP(rw http.ResponseWriter, clientreq *http.Request
|
|
|
var requestClosed int32
|
|
var requestClosed int32
|
|
|
completeCh := make(chan bool, 1)
|
|
completeCh := make(chan bool, 1)
|
|
|
closeNotifier, ok := rw.(http.CloseNotifier)
|
|
closeNotifier, ok := rw.(http.CloseNotifier)
|
|
|
- cancel := httputil.RequestCanceler(p.transport, proxyreq)
|
|
|
|
|
|
|
+ cancel := httputil.RequestCanceler(proxyreq)
|
|
|
if ok {
|
|
if ok {
|
|
|
closeCh := closeNotifier.CloseNotify()
|
|
closeCh := closeNotifier.CloseNotify()
|
|
|
go func() {
|
|
go func() {
|
Gyu-Ho Lee