astelm
/
grpcurl
mirror of https://github.com/fullstorydev/grpcurl.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix golint

This commit is contained in:
Cyrille Hemidy 2018-02-20 23:16:37 +01:00
parent 2ea74735a8
commit 01830654f7
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
testing/test_server.go
View File

@ -102,15 +102,17 @@ func (TestServer) StreamingInputCall(str grpc_testing.TestService_StreamingInput
if str.Context().Err() != nil { if str.Context().Err() != nil {
return str.Context().Err() return str.Context().Err()
} }
req, err := str.Recv() if req, err := str.Recv(); err != nil {
if err != nil { if err != nil {
if err == io.EOF { if err == io.EOF {
break break
} }
return err return err
} }
} else {
sz += len(req.Payload.Body) sz += len(req.Payload.Body)
} }
}
if err := str.SendAndClose(&grpc_testing.StreamingInputCallResponse{AggregatedPayloadSize: int32(sz)}); err != nil { if err := str.SendAndClose(&grpc_testing.StreamingInputCallResponse{AggregatedPayloadSize: int32(sz)}); err != nil {
return err return err
} }
@ -180,15 +182,15 @@ func (TestServer) HalfDuplexCall(str grpc_testing.TestService_HalfDuplexCallServ
if str.Context().Err() != nil { if str.Context().Err() != nil {
return str.Context().Err() return str.Context().Err()
} }
req, err := str.Recv() if req, err := str.Recv(); err != nil {
if err != nil {
if err == io.EOF { if err == io.EOF {
break break
} }
return err return err
} } else {
reqs = append(reqs, req) reqs = append(reqs, req)
} }
}
rsp := &grpc_testing.StreamingOutputCallResponse{} rsp := &grpc_testing.StreamingOutputCallResponse{}
for _, req := range reqs { for _, req := range reqs {
rsp.Payload = req.Payload rsp.Payload = req.Payload