Skip to content

Commit 01da659

Browse files
committed
Fixing err handling of writers
1 parent cd14149 commit 01da659

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/epp/handlers/streamingserver.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ func (s *StreamingServer) Process(srv extProcPb.ExternalProcessor_ProcessServer)
9494
case *extProcPb.ProcessingRequest_RequestBody:
9595
loggerVerbose.Info("Incoming body chunk", "body", string(v.RequestBody.Body), "EoS", v.RequestBody.EndOfStream)
9696
go func() {
97-
_, err = writer.Write(v.RequestBody.Body)
97+
_, err := writer.Write(v.RequestBody.Body)
9898
if err != nil {
9999
logger.V(logutil.DEFAULT).Error(err, "Error populating writer")
100100
}
@@ -154,7 +154,7 @@ func (s *StreamingServer) Process(srv extProcPb.ExternalProcessor_ProcessServer)
154154

155155
case *extProcPb.ProcessingRequest_ResponseBody:
156156
go func() {
157-
_, err = writer.Write(v.ResponseBody.Body)
157+
_, err := writer.Write(v.ResponseBody.Body)
158158
if err != nil {
159159
logger.V(logutil.DEFAULT).Error(err, "Error populating writer")
160160
}

0 commit comments

Comments
 (0)