Skip to content

Commit 2f7159a

Browse files
committed
Add missing Flush() call
1 parent 043649f commit 2f7159a

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

Diff for: datastream_server.go

+6
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,12 @@ func (stream *SimpleServerStream) ProcessRequest() {
112112
http.DefaultServeMux.ServeHTTP(w, req)
113113
}
114114

115+
err := w.w.Flush()
116+
if err != nil {
117+
fmt.Println("?????", err)
118+
return // XXX
119+
}
120+
115121
stream.sessionFnChan <- func() {
116122
if stream.closed {
117123
return

0 commit comments

Comments
 (0)