examples/addsvc: fix gRPC crashing bug
Peter Bourgon
7 years ago
42 | 42 | |
43 | 43 | func (s *grpcServer) Sum(ctx context.Context, req *pb.SumRequest) (*pb.SumReply, error) { |
44 | 44 | _, rep, err := s.sum.ServeGRPC(ctx, req) |
45 | return rep.(*pb.SumReply), err | |
45 | if err != nil { | |
46 | return nil, err | |
47 | } | |
48 | return rep.(*pb.SumReply), nil | |
46 | 49 | } |
47 | 50 | |
48 | 51 | func (s *grpcServer) Concat(ctx context.Context, req *pb.ConcatRequest) (*pb.ConcatReply, error) { |
49 | 52 | _, rep, err := s.concat.ServeGRPC(ctx, req) |
50 | return rep.(*pb.ConcatReply), err | |
53 | if err != nil { | |
54 | return nil, err | |
55 | } | |
56 | return rep.(*pb.ConcatReply), nil | |
51 | 57 | } |
52 | 58 | |
53 | 59 | // DecodeGRPCSumRequest is a transport/grpc.DecodeRequestFunc that converts a |