From aa440113cb9f59eb58c98151b8bc9bc813f7f195 Mon Sep 17 00:00:00 2001 From: e1732a364fed <75717694+e1732a364fed@users.noreply.github.com> Date: Sat, 1 Jan 2000 00:00:00 +0000 Subject: [PATCH] try fix #240, add flush to grpcSimple --- advLayer/grpcSimple/server.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/advLayer/grpcSimple/server.go b/advLayer/grpcSimple/server.go index 0c7c3d3..68c53d7 100644 --- a/advLayer/grpcSimple/server.go +++ b/advLayer/grpcSimple/server.go @@ -123,7 +123,7 @@ func (s *Server) StartHandle(underlay net.Conn, newSubConnFunc func(net.Conn), f return } - //log.Println("request headers", rq.Header) + //log.Println("request headers", rq.ContentLength, rq.Header) shouldFallback := false @@ -208,6 +208,9 @@ func (s *Server) StartHandle(underlay net.Conn, newSubConnFunc func(net.Conn), f } } rw.WriteHeader(http.StatusOK) + if flusher, ok := rw.(http.Flusher); ok { + flusher.Flush() + } sc := newServerConn(rw, rq) if s.closed {