diff --git a/core/core.go b/core/core.go index dabdee9d..ac469065 100644 --- a/core/core.go +++ b/core/core.go @@ -19,7 +19,7 @@ import ( var ( Version_x byte = 24 Version_y byte = 11 - Version_z byte = 21 + Version_z byte = 30 ) var ( diff --git a/transport/internet/splithttp/hub.go b/transport/internet/splithttp/hub.go index f1002018..17e1deef 100644 --- a/transport/internet/splithttp/hub.go +++ b/transport/internet/splithttp/hub.go @@ -159,9 +159,6 @@ func (h *requestHandler) ServeHTTP(writer http.ResponseWriter, request *http.Req errors.LogInfoInner(context.Background(), err, "failed to upload (PushReader)") writer.WriteHeader(http.StatusConflict) } else { - if request.Header.Get("Content-Type") == "application/grpc" { - writer.Header().Set("Content-Type", "application/grpc") - } writer.WriteHeader(http.StatusOK) <-request.Context().Done() } @@ -227,9 +224,7 @@ func (h *requestHandler) ServeHTTP(writer http.ResponseWriter, request *http.Req // teeing the response stream into their cache, causing slowdowns. writer.Header().Set("Cache-Control", "no-store") - if request.Header.Get("Content-Type") == "application/grpc" { - writer.Header().Set("Content-Type", "application/grpc") - } else if !h.config.NoSSEHeader { + if !h.config.NoSSEHeader { // magic header to make the HTTP middle box consider this as SSE to disable buffer writer.Header().Set("Content-Type", "text/event-stream") }