Skip to content

Commit 104e852

Browse files
author
王录祥
committed
add request header
1 parent 6f85a68 commit 104e852

File tree

2 files changed

+3
-10
lines changed

2 files changed

+3
-10
lines changed

server/hooks.go

Lines changed: 2 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

server/sse.go

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -221,15 +221,7 @@ func (s *SSEServer) handleSSE(w http.ResponseWriter, r *http.Request) {
221221
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
222222
return
223223
}
224-
header := make(map[string]string)
225-
for k, v := range r.Header {
226-
header[k] = v[0]
227-
}
228-
err := s.server.hooks.onConnectSSE(header)
229-
if err != nil {
230-
http.Error(w, fmt.Sprintf("connect SSE failed: %v", err), http.StatusInternalServerError)
231-
return
232-
}
224+
233225
w.Header().Set("Content-Type", "text/event-stream")
234226
w.Header().Set("Cache-Control", "no-cache")
235227
w.Header().Set("Connection", "keep-alive")

0 commit comments

Comments
 (0)