func DoByteBufStreamingRoundTrip(stream testpb.BenchmarkService_StreamingCallClient, reqSize, respSize int) error {
	out := make([]byte, reqSize)
	if err := stream.(grpc.ClientStream).SendMsg(&out); err != nil {
		return fmt.Errorf("/BenchmarkService/StreamingCall.(ClientStream).SendMsg(_) = %v, want <nil>", err)
	}
	var in []byte
	if err := stream.(grpc.ClientStream).RecvMsg(&in); err != nil {
		// EOF is a valid error here.
		if err == io.EOF {
			return nil
		}
		return fmt.Errorf("/BenchmarkService/StreamingCall.(ClientStream).RecvMsg(_) = %v, want <nil>", err)
	}
	return nil
}
// DoByteBufStreamingRoundTrip performs a round trip for a single streaming rpc, using a custom codec for byte buffer.
DoByteBufStreamingRoundTrip performs a round trip for a single streaming rpc, using a custom codec for byte buffer.
// DoByteBufStreamingRoundTrip performs a round trip for a single streaming rpc using a custom codec for byte buffer .
func DoByteBufStreamingRoundTrip(stream testpb.BenchmarkService_StreamingCallClient, reqSize, respSize int) error {
	out := make([]byte, reqSize)
	if err := stream.(grpc.ClientStream).SendMsg(&out); err != nil {
		return fmt.Errorf("/BenchmarkService/StreamingCall.(ClientStream).SendMsg(_) = %v, want <nil>", err)
	}
	var in []byte
	if err := stream.(grpc.ClientStream).RecvMsg(&in); err != nil {
		if err == io.EOF {
			return nil
		}
		return fmt.Errorf("/BenchmarkService/StreamingCall.(ClientStream).RecvMsg(_) = %v, want <nil>", err)
	}
	return nil
}
func DoByteBufStreamingRoundTrip ( stream testpb . BenchmarkService_StreamingCallClient , reqSize , respSize int ) error { out := make ( [ ] byte , reqSize ) if err := stream . ( grpc . ClientStream ) . SendMsg ( & out ) ; err != nil { return fmt . Errorf ( " " , err ) } var in [ ] byte if err := stream . ( grpc . ClientStream ) . RecvMsg ( & in ) ; err != nil { if err == io . EOF { return nil } return fmt . Errorf ( " " , err ) } return nil }
DoByteBufStreamingRoundTrip performs a round trip for a single streaming rpc, using a custom codec for byte buffer.
DoByteBufStreamingRoundTrip performs a round trip for a single streaming rpc using a custom codec for byte buffer .
// EOF is a valid error here.