try fix #240, add flush to grpcSimple

e1732a364fed · Feb 12, 2023 · aa44011 · aa44011
1 parent 825d60c
commit aa44011
Showing 1 changed file with 4 additions and 1 deletion.
diff --git 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 {