(streams [][]testgrpc.BenchmarkService_StreamingCallClient, req *testpb.SimpleRequest)
| 521 | } |
| 522 | |
| 523 | func prepareMessages(streams [][]testgrpc.BenchmarkService_StreamingCallClient, req *testpb.SimpleRequest) [][]*grpc.PreparedMsg { |
| 524 | preparedMsg := make([][]*grpc.PreparedMsg, len(streams)) |
| 525 | for cn, connStreams := range streams { |
| 526 | preparedMsg[cn] = make([]*grpc.PreparedMsg, len(connStreams)) |
| 527 | for pos, stream := range connStreams { |
| 528 | preparedMsg[cn][pos] = &grpc.PreparedMsg{} |
| 529 | if err := preparedMsg[cn][pos].Encode(stream, req); err != nil { |
| 530 | logger.Fatalf("%v.Encode(%v, %v) = %v", preparedMsg[cn][pos], req, stream, err) |
| 531 | } |
| 532 | } |
| 533 | } |
| 534 | return preparedMsg |
| 535 | } |
| 536 | |
| 537 | // Makes a UnaryCall gRPC request using the given BenchmarkServiceClient and |
| 538 | // request and response sizes. |
no test coverage detected