opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Move the server-side handling code from StreamingOutputCall to FullDuplexCall.

Browse Source
This commit is contained in:
Mark D. Roth
2016-07-01 09:32:29 -07:00
parent fa1bb7b833
commit f9584a00cf
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
interop/test_utils.go
View File

@ -542,10 +542,6 @@ func (s *testServer) UnaryCall(ctx context.Context, in *testpb.SimpleRequest) (*
} }
func (s *testServer) StreamingOutputCall(args *testpb.StreamingOutputCallRequest, stream testpb.TestService_StreamingOutputCallServer) error { func (s *testServer) StreamingOutputCall(args *testpb.StreamingOutputCallRequest, stream testpb.TestService_StreamingOutputCallServer) error {
resp := args.GetResponseStatus()
if resp != nil && *resp.Code != 0 {
return grpc.Errorf(codes.Code(*resp.Code), *resp.Message)
}
cs := args.GetResponseParameters() cs := args.GetResponseParameters()
for _, c := range cs { for _, c := range cs {
if us := c.GetIntervalUs(); us > 0 { if us := c.GetIntervalUs(); us > 0 {
@ -591,6 +587,10 @@ func (s *testServer) FullDuplexCall(stream testpb.TestService_FullDuplexCallServ
if err != nil { if err != nil {
return err return err
} }
resp := in.GetResponseStatus()
if resp != nil && *resp.Code != 0 {
return grpc.Errorf(codes.Code(*resp.Code), *resp.Message)
}
cs := in.GetResponseParameters() cs := in.GetResponseParameters()
for _, c := range cs { for _, c := range cs {
if us := c.GetIntervalUs(); us > 0 { if us := c.GetIntervalUs(); us > 0 {