(args *testpb.StreamingOutputCallRequest, stream testgrpc.TestService_StreamingOutputCallServer)
| 767 | } |
| 768 | |
| 769 | func (s *testServer) StreamingOutputCall(args *testpb.StreamingOutputCallRequest, stream testgrpc.TestService_StreamingOutputCallServer) error { |
| 770 | cs := args.GetResponseParameters() |
| 771 | for _, c := range cs { |
| 772 | if us := c.GetIntervalUs(); us > 0 { |
| 773 | time.Sleep(time.Duration(us) * time.Microsecond) |
| 774 | } |
| 775 | pl, err := serverNewPayload(args.GetResponseType(), c.GetSize()) |
| 776 | if err != nil { |
| 777 | return err |
| 778 | } |
| 779 | if err := stream.Send(&testpb.StreamingOutputCallResponse{ |
| 780 | Payload: pl, |
| 781 | }); err != nil { |
| 782 | return err |
| 783 | } |
| 784 | } |
| 785 | return nil |
| 786 | } |
| 787 | |
| 788 | func (s *testServer) StreamingInputCall(stream testgrpc.TestService_StreamingInputCallServer) error { |
| 789 | var sum int |
nothing calls this directly
no test coverage detected