|
@@ -15,7 +15,6 @@ import (
|
|
type ResponseModifier interface {
|
|
type ResponseModifier interface {
|
|
http.ResponseWriter
|
|
http.ResponseWriter
|
|
http.Flusher
|
|
http.Flusher
|
|
- http.CloseNotifier
|
|
|
|
|
|
|
|
// RawBody returns the current http content
|
|
// RawBody returns the current http content
|
|
RawBody() []byte
|
|
RawBody() []byte
|
|
@@ -155,16 +154,6 @@ func (rm *responseModifier) Hijack() (net.Conn, *bufio.ReadWriter, error) {
|
|
return hijacker.Hijack()
|
|
return hijacker.Hijack()
|
|
}
|
|
}
|
|
|
|
|
|
-// CloseNotify uses the internal close notify API of the wrapped http.ResponseWriter
|
|
|
|
-func (rm *responseModifier) CloseNotify() <-chan bool {
|
|
|
|
- closeNotifier, ok := rm.rw.(http.CloseNotifier)
|
|
|
|
- if !ok {
|
|
|
|
- logrus.Error("Internal response writer doesn't support the CloseNotifier interface")
|
|
|
|
- return nil
|
|
|
|
- }
|
|
|
|
- return closeNotifier.CloseNotify()
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
// Flush uses the internal flush API of the wrapped http.ResponseWriter
|
|
// Flush uses the internal flush API of the wrapped http.ResponseWriter
|
|
func (rm *responseModifier) Flush() {
|
|
func (rm *responseModifier) Flush() {
|
|
flusher, ok := rm.rw.(http.Flusher)
|
|
flusher, ok := rm.rw.(http.Flusher)
|