func DoStreamingRoundTrip(stream testpb.BenchmarkService_StreamingCallClient, reqSize, respSize int) error {
	pl := newPayload(testpb.PayloadType_COMPRESSABLE, reqSize)
	req := &testpb.SimpleRequest{
		ResponseType: pl.Type,
		ResponseSize: int32(respSize),
		Payload:      pl,
	}
	if err := stream.Send(req); err != nil {
		return fmt.Errorf("/BenchmarkService/StreamingCall.Send(_) = %v, want <nil>", err)
	}
	if _, err := stream.Recv(); err != nil {
		// EOF is a valid error here.
		if err == io.EOF {
			return nil
		}
		return fmt.Errorf("/BenchmarkService/StreamingCall.Recv(_) = %v, want <nil>", err)
	}
	return nil
}
// DoStreamingRoundTrip performs a round trip for a single streaming rpc.
DoStreamingRoundTrip performs a round trip for a single streaming rpc.
// DoStreamingRoundTrip performs a round trip for a single streaming rpc .
func DoStreamingRoundTrip(stream testpb.BenchmarkService_StreamingCallClient, reqSize, respSize int) error {
	pl := newPayload(testpb.PayloadType_COMPRESSABLE, reqSize)
	req := &testpb.SimpleRequest{
		ResponseType: pl.Type,
		ResponseSize: int32(respSize),
		Payload:      pl,
	}
	if err := stream.Send(req); err != nil {
		return fmt.Errorf("/BenchmarkService/StreamingCall.Send(_) = %v, want <nil>", err)
	}
	if _, err := stream.Recv(); err != nil {
		if err == io.EOF {
			return nil
		}
		return fmt.Errorf("/BenchmarkService/StreamingCall.Recv(_) = %v, want <nil>", err)
	}
	return nil
}
func DoStreamingRoundTrip ( stream testpb . BenchmarkService_StreamingCallClient , reqSize , respSize int ) error { pl := newPayload ( testpb . PayloadType_COMPRESSABLE , reqSize ) req := & testpb . SimpleRequest { ResponseType : pl . Type , ResponseSize : int32 ( respSize ) , Payload : pl , } if err := stream . Send ( req ) ; err != nil { return fmt . Errorf ( " " , err ) } if _ , err := stream . Recv ( ) ; err != nil { if err == io . EOF { return nil } return fmt . Errorf ( " " , err ) } return nil }
DoStreamingRoundTrip performs a round trip for a single streaming rpc.
DoStreamingRoundTrip performs a round trip for a single streaming rpc .
// EOF is a valid error here.