Matthew Stevenson
6 years ago
commit
a3dde11f68
29 changed files with 185 additions and 1264 deletions
@ -1,63 +0,0 @@ |
|||||||
#region Copyright notice and license |
|
||||||
|
|
||||||
// Copyright 2019 The gRPC Authors |
|
||||||
// |
|
||||||
// Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
// you may not use this file except in compliance with the License. |
|
||||||
// You may obtain a copy of the License at |
|
||||||
// |
|
||||||
// http://www.apache.org/licenses/LICENSE-2.0 |
|
||||||
// |
|
||||||
// Unless required by applicable law or agreed to in writing, software |
|
||||||
// distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
// See the License for the specific language governing permissions and |
|
||||||
// limitations under the License. |
|
||||||
|
|
||||||
#endregion |
|
||||||
|
|
||||||
using System; |
|
||||||
using Grpc.Core.Internal; |
|
||||||
using Grpc.Core.Utils; |
|
||||||
|
|
||||||
namespace Grpc.Core |
|
||||||
{ |
|
||||||
/// <summary> |
|
||||||
/// Base class for lightweight client-side stubs. |
|
||||||
/// All calls are invoked via a <c>CallInvoker</c>. |
|
||||||
/// Lite client stubs have no configuration knobs, all configuration |
|
||||||
/// is provided by decorating the call invoker. |
|
||||||
/// Note: experimental API that can change or be removed without any prior notice. |
|
||||||
/// </summary> |
|
||||||
public abstract class LiteClientBase |
|
||||||
{ |
|
||||||
readonly CallInvoker callInvoker; |
|
||||||
|
|
||||||
/// <summary> |
|
||||||
/// Initializes a new instance of <c>LiteClientBase</c> class that |
|
||||||
/// throws <c>NotImplementedException</c> upon invocation of any RPC. |
|
||||||
/// This constructor is only provided to allow creation of test doubles |
|
||||||
/// for client classes (e.g. mocking requires a parameterless constructor). |
|
||||||
/// </summary> |
|
||||||
protected LiteClientBase() : this(new UnimplementedCallInvoker()) |
|
||||||
{ |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary> |
|
||||||
/// Initializes a new instance of <c>ClientBase</c> class. |
|
||||||
/// </summary> |
|
||||||
/// <param name="callInvoker">The <c>CallInvoker</c> for remote call invocation.</param> |
|
||||||
public LiteClientBase(CallInvoker callInvoker) |
|
||||||
{ |
|
||||||
this.callInvoker = GrpcPreconditions.CheckNotNull(callInvoker, nameof(callInvoker)); |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary> |
|
||||||
/// Gets the call invoker. |
|
||||||
/// </summary> |
|
||||||
protected CallInvoker CallInvoker |
|
||||||
{ |
|
||||||
get { return this.callInvoker; } |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
@ -1,759 +0,0 @@ |
|||||||
// <auto-generated> |
|
||||||
// Generated by the protocol buffer compiler. DO NOT EDIT! |
|
||||||
// source: math_with_protoc_options.proto |
|
||||||
// </auto-generated> |
|
||||||
#pragma warning disable 1591, 0612, 3021 |
|
||||||
#region Designer generated code |
|
||||||
|
|
||||||
using pb = global::Google.Protobuf; |
|
||||||
using pbc = global::Google.Protobuf.Collections; |
|
||||||
using pbr = global::Google.Protobuf.Reflection; |
|
||||||
using scg = global::System.Collections.Generic; |
|
||||||
namespace MathWithProtocOptions { |
|
||||||
|
|
||||||
/// <summary>Holder for reflection information generated from math_with_protoc_options.proto</summary> |
|
||||||
public static partial class MathWithProtocOptionsReflection { |
|
||||||
|
|
||||||
#region Descriptor |
|
||||||
/// <summary>File descriptor for math_with_protoc_options.proto</summary> |
|
||||||
public static pbr::FileDescriptor Descriptor { |
|
||||||
get { return descriptor; } |
|
||||||
} |
|
||||||
private static pbr::FileDescriptor descriptor; |
|
||||||
|
|
||||||
static MathWithProtocOptionsReflection() { |
|
||||||
byte[] descriptorData = global::System.Convert.FromBase64String( |
|
||||||
string.Concat( |
|
||||||
"Ch5tYXRoX3dpdGhfcHJvdG9jX29wdGlvbnMucHJvdG8SGG1hdGhfd2l0aF9w", |
|
||||||
"cm90b2Nfb3B0aW9ucyIsCgdEaXZBcmdzEhAKCGRpdmlkZW5kGAEgASgDEg8K", |
|
||||||
"B2Rpdmlzb3IYAiABKAMiLwoIRGl2UmVwbHkSEAoIcXVvdGllbnQYASABKAMS", |
|
||||||
"EQoJcmVtYWluZGVyGAIgASgDIhgKB0ZpYkFyZ3MSDQoFbGltaXQYASABKAMi", |
|
||||||
"EgoDTnVtEgsKA251bRgBIAEoAyIZCghGaWJSZXBseRINCgVjb3VudBgBIAEo", |
|
||||||
"AzLEAgoETWF0aBJOCgNEaXYSIS5tYXRoX3dpdGhfcHJvdG9jX29wdGlvbnMu", |
|
||||||
"RGl2QXJncxoiLm1hdGhfd2l0aF9wcm90b2Nfb3B0aW9ucy5EaXZSZXBseSIA", |
|
||||||
"ElYKB0Rpdk1hbnkSIS5tYXRoX3dpdGhfcHJvdG9jX29wdGlvbnMuRGl2QXJn", |
|
||||||
"cxoiLm1hdGhfd2l0aF9wcm90b2Nfb3B0aW9ucy5EaXZSZXBseSIAKAEwARJL", |
|
||||||
"CgNGaWISIS5tYXRoX3dpdGhfcHJvdG9jX29wdGlvbnMuRmliQXJncxodLm1h", |
|
||||||
"dGhfd2l0aF9wcm90b2Nfb3B0aW9ucy5OdW0iADABEkcKA1N1bRIdLm1hdGhf", |
|
||||||
"d2l0aF9wcm90b2Nfb3B0aW9ucy5OdW0aHS5tYXRoX3dpdGhfcHJvdG9jX29w", |
|
||||||
"dGlvbnMuTnVtIgAoAWIGcHJvdG8z")); |
|
||||||
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData, |
|
||||||
new pbr::FileDescriptor[] { }, |
|
||||||
new pbr::GeneratedClrTypeInfo(null, new pbr::GeneratedClrTypeInfo[] { |
|
||||||
new pbr::GeneratedClrTypeInfo(typeof(global::MathWithProtocOptions.DivArgs), global::MathWithProtocOptions.DivArgs.Parser, new[]{ "Dividend", "Divisor" }, null, null, null), |
|
||||||
new pbr::GeneratedClrTypeInfo(typeof(global::MathWithProtocOptions.DivReply), global::MathWithProtocOptions.DivReply.Parser, new[]{ "Quotient", "Remainder" }, null, null, null), |
|
||||||
new pbr::GeneratedClrTypeInfo(typeof(global::MathWithProtocOptions.FibArgs), global::MathWithProtocOptions.FibArgs.Parser, new[]{ "Limit" }, null, null, null), |
|
||||||
new pbr::GeneratedClrTypeInfo(typeof(global::MathWithProtocOptions.Num), global::MathWithProtocOptions.Num.Parser, new[]{ "Num_" }, null, null, null), |
|
||||||
new pbr::GeneratedClrTypeInfo(typeof(global::MathWithProtocOptions.FibReply), global::MathWithProtocOptions.FibReply.Parser, new[]{ "Count" }, null, null, null) |
|
||||||
})); |
|
||||||
} |
|
||||||
#endregion |
|
||||||
|
|
||||||
} |
|
||||||
#region Messages |
|
||||||
public sealed partial class DivArgs : pb::IMessage<DivArgs> { |
|
||||||
private static readonly pb::MessageParser<DivArgs> _parser = new pb::MessageParser<DivArgs>(() => new DivArgs()); |
|
||||||
private pb::UnknownFieldSet _unknownFields; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pb::MessageParser<DivArgs> Parser { get { return _parser; } } |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pbr::MessageDescriptor Descriptor { |
|
||||||
get { return global::MathWithProtocOptions.MathWithProtocOptionsReflection.Descriptor.MessageTypes[0]; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
pbr::MessageDescriptor pb::IMessage.Descriptor { |
|
||||||
get { return Descriptor; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public DivArgs() { |
|
||||||
OnConstruction(); |
|
||||||
} |
|
||||||
|
|
||||||
partial void OnConstruction(); |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public DivArgs(DivArgs other) : this() { |
|
||||||
dividend_ = other.dividend_; |
|
||||||
divisor_ = other.divisor_; |
|
||||||
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public DivArgs Clone() { |
|
||||||
return new DivArgs(this); |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary>Field number for the "dividend" field.</summary> |
|
||||||
public const int DividendFieldNumber = 1; |
|
||||||
private long dividend_; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public long Dividend { |
|
||||||
get { return dividend_; } |
|
||||||
set { |
|
||||||
dividend_ = value; |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary>Field number for the "divisor" field.</summary> |
|
||||||
public const int DivisorFieldNumber = 2; |
|
||||||
private long divisor_; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public long Divisor { |
|
||||||
get { return divisor_; } |
|
||||||
set { |
|
||||||
divisor_ = value; |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override bool Equals(object other) { |
|
||||||
return Equals(other as DivArgs); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public bool Equals(DivArgs other) { |
|
||||||
if (ReferenceEquals(other, null)) { |
|
||||||
return false; |
|
||||||
} |
|
||||||
if (ReferenceEquals(other, this)) { |
|
||||||
return true; |
|
||||||
} |
|
||||||
if (Dividend != other.Dividend) return false; |
|
||||||
if (Divisor != other.Divisor) return false; |
|
||||||
return Equals(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override int GetHashCode() { |
|
||||||
int hash = 1; |
|
||||||
if (Dividend != 0L) hash ^= Dividend.GetHashCode(); |
|
||||||
if (Divisor != 0L) hash ^= Divisor.GetHashCode(); |
|
||||||
if (_unknownFields != null) { |
|
||||||
hash ^= _unknownFields.GetHashCode(); |
|
||||||
} |
|
||||||
return hash; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override string ToString() { |
|
||||||
return pb::JsonFormatter.ToDiagnosticString(this); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void WriteTo(pb::CodedOutputStream output) { |
|
||||||
if (Dividend != 0L) { |
|
||||||
output.WriteRawTag(8); |
|
||||||
output.WriteInt64(Dividend); |
|
||||||
} |
|
||||||
if (Divisor != 0L) { |
|
||||||
output.WriteRawTag(16); |
|
||||||
output.WriteInt64(Divisor); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
_unknownFields.WriteTo(output); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public int CalculateSize() { |
|
||||||
int size = 0; |
|
||||||
if (Dividend != 0L) { |
|
||||||
size += 1 + pb::CodedOutputStream.ComputeInt64Size(Dividend); |
|
||||||
} |
|
||||||
if (Divisor != 0L) { |
|
||||||
size += 1 + pb::CodedOutputStream.ComputeInt64Size(Divisor); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
size += _unknownFields.CalculateSize(); |
|
||||||
} |
|
||||||
return size; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(DivArgs other) { |
|
||||||
if (other == null) { |
|
||||||
return; |
|
||||||
} |
|
||||||
if (other.Dividend != 0L) { |
|
||||||
Dividend = other.Dividend; |
|
||||||
} |
|
||||||
if (other.Divisor != 0L) { |
|
||||||
Divisor = other.Divisor; |
|
||||||
} |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(pb::CodedInputStream input) { |
|
||||||
uint tag; |
|
||||||
while ((tag = input.ReadTag()) != 0) { |
|
||||||
switch(tag) { |
|
||||||
default: |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, input); |
|
||||||
break; |
|
||||||
case 8: { |
|
||||||
Dividend = input.ReadInt64(); |
|
||||||
break; |
|
||||||
} |
|
||||||
case 16: { |
|
||||||
Divisor = input.ReadInt64(); |
|
||||||
break; |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
|
|
||||||
public sealed partial class DivReply : pb::IMessage<DivReply> { |
|
||||||
private static readonly pb::MessageParser<DivReply> _parser = new pb::MessageParser<DivReply>(() => new DivReply()); |
|
||||||
private pb::UnknownFieldSet _unknownFields; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pb::MessageParser<DivReply> Parser { get { return _parser; } } |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pbr::MessageDescriptor Descriptor { |
|
||||||
get { return global::MathWithProtocOptions.MathWithProtocOptionsReflection.Descriptor.MessageTypes[1]; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
pbr::MessageDescriptor pb::IMessage.Descriptor { |
|
||||||
get { return Descriptor; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public DivReply() { |
|
||||||
OnConstruction(); |
|
||||||
} |
|
||||||
|
|
||||||
partial void OnConstruction(); |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public DivReply(DivReply other) : this() { |
|
||||||
quotient_ = other.quotient_; |
|
||||||
remainder_ = other.remainder_; |
|
||||||
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public DivReply Clone() { |
|
||||||
return new DivReply(this); |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary>Field number for the "quotient" field.</summary> |
|
||||||
public const int QuotientFieldNumber = 1; |
|
||||||
private long quotient_; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public long Quotient { |
|
||||||
get { return quotient_; } |
|
||||||
set { |
|
||||||
quotient_ = value; |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary>Field number for the "remainder" field.</summary> |
|
||||||
public const int RemainderFieldNumber = 2; |
|
||||||
private long remainder_; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public long Remainder { |
|
||||||
get { return remainder_; } |
|
||||||
set { |
|
||||||
remainder_ = value; |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override bool Equals(object other) { |
|
||||||
return Equals(other as DivReply); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public bool Equals(DivReply other) { |
|
||||||
if (ReferenceEquals(other, null)) { |
|
||||||
return false; |
|
||||||
} |
|
||||||
if (ReferenceEquals(other, this)) { |
|
||||||
return true; |
|
||||||
} |
|
||||||
if (Quotient != other.Quotient) return false; |
|
||||||
if (Remainder != other.Remainder) return false; |
|
||||||
return Equals(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override int GetHashCode() { |
|
||||||
int hash = 1; |
|
||||||
if (Quotient != 0L) hash ^= Quotient.GetHashCode(); |
|
||||||
if (Remainder != 0L) hash ^= Remainder.GetHashCode(); |
|
||||||
if (_unknownFields != null) { |
|
||||||
hash ^= _unknownFields.GetHashCode(); |
|
||||||
} |
|
||||||
return hash; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override string ToString() { |
|
||||||
return pb::JsonFormatter.ToDiagnosticString(this); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void WriteTo(pb::CodedOutputStream output) { |
|
||||||
if (Quotient != 0L) { |
|
||||||
output.WriteRawTag(8); |
|
||||||
output.WriteInt64(Quotient); |
|
||||||
} |
|
||||||
if (Remainder != 0L) { |
|
||||||
output.WriteRawTag(16); |
|
||||||
output.WriteInt64(Remainder); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
_unknownFields.WriteTo(output); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public int CalculateSize() { |
|
||||||
int size = 0; |
|
||||||
if (Quotient != 0L) { |
|
||||||
size += 1 + pb::CodedOutputStream.ComputeInt64Size(Quotient); |
|
||||||
} |
|
||||||
if (Remainder != 0L) { |
|
||||||
size += 1 + pb::CodedOutputStream.ComputeInt64Size(Remainder); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
size += _unknownFields.CalculateSize(); |
|
||||||
} |
|
||||||
return size; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(DivReply other) { |
|
||||||
if (other == null) { |
|
||||||
return; |
|
||||||
} |
|
||||||
if (other.Quotient != 0L) { |
|
||||||
Quotient = other.Quotient; |
|
||||||
} |
|
||||||
if (other.Remainder != 0L) { |
|
||||||
Remainder = other.Remainder; |
|
||||||
} |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(pb::CodedInputStream input) { |
|
||||||
uint tag; |
|
||||||
while ((tag = input.ReadTag()) != 0) { |
|
||||||
switch(tag) { |
|
||||||
default: |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, input); |
|
||||||
break; |
|
||||||
case 8: { |
|
||||||
Quotient = input.ReadInt64(); |
|
||||||
break; |
|
||||||
} |
|
||||||
case 16: { |
|
||||||
Remainder = input.ReadInt64(); |
|
||||||
break; |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
|
|
||||||
public sealed partial class FibArgs : pb::IMessage<FibArgs> { |
|
||||||
private static readonly pb::MessageParser<FibArgs> _parser = new pb::MessageParser<FibArgs>(() => new FibArgs()); |
|
||||||
private pb::UnknownFieldSet _unknownFields; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pb::MessageParser<FibArgs> Parser { get { return _parser; } } |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pbr::MessageDescriptor Descriptor { |
|
||||||
get { return global::MathWithProtocOptions.MathWithProtocOptionsReflection.Descriptor.MessageTypes[2]; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
pbr::MessageDescriptor pb::IMessage.Descriptor { |
|
||||||
get { return Descriptor; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public FibArgs() { |
|
||||||
OnConstruction(); |
|
||||||
} |
|
||||||
|
|
||||||
partial void OnConstruction(); |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public FibArgs(FibArgs other) : this() { |
|
||||||
limit_ = other.limit_; |
|
||||||
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public FibArgs Clone() { |
|
||||||
return new FibArgs(this); |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary>Field number for the "limit" field.</summary> |
|
||||||
public const int LimitFieldNumber = 1; |
|
||||||
private long limit_; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public long Limit { |
|
||||||
get { return limit_; } |
|
||||||
set { |
|
||||||
limit_ = value; |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override bool Equals(object other) { |
|
||||||
return Equals(other as FibArgs); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public bool Equals(FibArgs other) { |
|
||||||
if (ReferenceEquals(other, null)) { |
|
||||||
return false; |
|
||||||
} |
|
||||||
if (ReferenceEquals(other, this)) { |
|
||||||
return true; |
|
||||||
} |
|
||||||
if (Limit != other.Limit) return false; |
|
||||||
return Equals(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override int GetHashCode() { |
|
||||||
int hash = 1; |
|
||||||
if (Limit != 0L) hash ^= Limit.GetHashCode(); |
|
||||||
if (_unknownFields != null) { |
|
||||||
hash ^= _unknownFields.GetHashCode(); |
|
||||||
} |
|
||||||
return hash; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override string ToString() { |
|
||||||
return pb::JsonFormatter.ToDiagnosticString(this); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void WriteTo(pb::CodedOutputStream output) { |
|
||||||
if (Limit != 0L) { |
|
||||||
output.WriteRawTag(8); |
|
||||||
output.WriteInt64(Limit); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
_unknownFields.WriteTo(output); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public int CalculateSize() { |
|
||||||
int size = 0; |
|
||||||
if (Limit != 0L) { |
|
||||||
size += 1 + pb::CodedOutputStream.ComputeInt64Size(Limit); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
size += _unknownFields.CalculateSize(); |
|
||||||
} |
|
||||||
return size; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(FibArgs other) { |
|
||||||
if (other == null) { |
|
||||||
return; |
|
||||||
} |
|
||||||
if (other.Limit != 0L) { |
|
||||||
Limit = other.Limit; |
|
||||||
} |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(pb::CodedInputStream input) { |
|
||||||
uint tag; |
|
||||||
while ((tag = input.ReadTag()) != 0) { |
|
||||||
switch(tag) { |
|
||||||
default: |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, input); |
|
||||||
break; |
|
||||||
case 8: { |
|
||||||
Limit = input.ReadInt64(); |
|
||||||
break; |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
|
|
||||||
public sealed partial class Num : pb::IMessage<Num> { |
|
||||||
private static readonly pb::MessageParser<Num> _parser = new pb::MessageParser<Num>(() => new Num()); |
|
||||||
private pb::UnknownFieldSet _unknownFields; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pb::MessageParser<Num> Parser { get { return _parser; } } |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pbr::MessageDescriptor Descriptor { |
|
||||||
get { return global::MathWithProtocOptions.MathWithProtocOptionsReflection.Descriptor.MessageTypes[3]; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
pbr::MessageDescriptor pb::IMessage.Descriptor { |
|
||||||
get { return Descriptor; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public Num() { |
|
||||||
OnConstruction(); |
|
||||||
} |
|
||||||
|
|
||||||
partial void OnConstruction(); |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public Num(Num other) : this() { |
|
||||||
num_ = other.num_; |
|
||||||
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public Num Clone() { |
|
||||||
return new Num(this); |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary>Field number for the "num" field.</summary> |
|
||||||
public const int Num_FieldNumber = 1; |
|
||||||
private long num_; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public long Num_ { |
|
||||||
get { return num_; } |
|
||||||
set { |
|
||||||
num_ = value; |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override bool Equals(object other) { |
|
||||||
return Equals(other as Num); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public bool Equals(Num other) { |
|
||||||
if (ReferenceEquals(other, null)) { |
|
||||||
return false; |
|
||||||
} |
|
||||||
if (ReferenceEquals(other, this)) { |
|
||||||
return true; |
|
||||||
} |
|
||||||
if (Num_ != other.Num_) return false; |
|
||||||
return Equals(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override int GetHashCode() { |
|
||||||
int hash = 1; |
|
||||||
if (Num_ != 0L) hash ^= Num_.GetHashCode(); |
|
||||||
if (_unknownFields != null) { |
|
||||||
hash ^= _unknownFields.GetHashCode(); |
|
||||||
} |
|
||||||
return hash; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override string ToString() { |
|
||||||
return pb::JsonFormatter.ToDiagnosticString(this); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void WriteTo(pb::CodedOutputStream output) { |
|
||||||
if (Num_ != 0L) { |
|
||||||
output.WriteRawTag(8); |
|
||||||
output.WriteInt64(Num_); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
_unknownFields.WriteTo(output); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public int CalculateSize() { |
|
||||||
int size = 0; |
|
||||||
if (Num_ != 0L) { |
|
||||||
size += 1 + pb::CodedOutputStream.ComputeInt64Size(Num_); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
size += _unknownFields.CalculateSize(); |
|
||||||
} |
|
||||||
return size; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(Num other) { |
|
||||||
if (other == null) { |
|
||||||
return; |
|
||||||
} |
|
||||||
if (other.Num_ != 0L) { |
|
||||||
Num_ = other.Num_; |
|
||||||
} |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(pb::CodedInputStream input) { |
|
||||||
uint tag; |
|
||||||
while ((tag = input.ReadTag()) != 0) { |
|
||||||
switch(tag) { |
|
||||||
default: |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, input); |
|
||||||
break; |
|
||||||
case 8: { |
|
||||||
Num_ = input.ReadInt64(); |
|
||||||
break; |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
|
|
||||||
public sealed partial class FibReply : pb::IMessage<FibReply> { |
|
||||||
private static readonly pb::MessageParser<FibReply> _parser = new pb::MessageParser<FibReply>(() => new FibReply()); |
|
||||||
private pb::UnknownFieldSet _unknownFields; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pb::MessageParser<FibReply> Parser { get { return _parser; } } |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public static pbr::MessageDescriptor Descriptor { |
|
||||||
get { return global::MathWithProtocOptions.MathWithProtocOptionsReflection.Descriptor.MessageTypes[4]; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
pbr::MessageDescriptor pb::IMessage.Descriptor { |
|
||||||
get { return Descriptor; } |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public FibReply() { |
|
||||||
OnConstruction(); |
|
||||||
} |
|
||||||
|
|
||||||
partial void OnConstruction(); |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public FibReply(FibReply other) : this() { |
|
||||||
count_ = other.count_; |
|
||||||
_unknownFields = pb::UnknownFieldSet.Clone(other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public FibReply Clone() { |
|
||||||
return new FibReply(this); |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary>Field number for the "count" field.</summary> |
|
||||||
public const int CountFieldNumber = 1; |
|
||||||
private long count_; |
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public long Count { |
|
||||||
get { return count_; } |
|
||||||
set { |
|
||||||
count_ = value; |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override bool Equals(object other) { |
|
||||||
return Equals(other as FibReply); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public bool Equals(FibReply other) { |
|
||||||
if (ReferenceEquals(other, null)) { |
|
||||||
return false; |
|
||||||
} |
|
||||||
if (ReferenceEquals(other, this)) { |
|
||||||
return true; |
|
||||||
} |
|
||||||
if (Count != other.Count) return false; |
|
||||||
return Equals(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override int GetHashCode() { |
|
||||||
int hash = 1; |
|
||||||
if (Count != 0L) hash ^= Count.GetHashCode(); |
|
||||||
if (_unknownFields != null) { |
|
||||||
hash ^= _unknownFields.GetHashCode(); |
|
||||||
} |
|
||||||
return hash; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public override string ToString() { |
|
||||||
return pb::JsonFormatter.ToDiagnosticString(this); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void WriteTo(pb::CodedOutputStream output) { |
|
||||||
if (Count != 0L) { |
|
||||||
output.WriteRawTag(8); |
|
||||||
output.WriteInt64(Count); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
_unknownFields.WriteTo(output); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public int CalculateSize() { |
|
||||||
int size = 0; |
|
||||||
if (Count != 0L) { |
|
||||||
size += 1 + pb::CodedOutputStream.ComputeInt64Size(Count); |
|
||||||
} |
|
||||||
if (_unknownFields != null) { |
|
||||||
size += _unknownFields.CalculateSize(); |
|
||||||
} |
|
||||||
return size; |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(FibReply other) { |
|
||||||
if (other == null) { |
|
||||||
return; |
|
||||||
} |
|
||||||
if (other.Count != 0L) { |
|
||||||
Count = other.Count; |
|
||||||
} |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFrom(_unknownFields, other._unknownFields); |
|
||||||
} |
|
||||||
|
|
||||||
[global::System.Diagnostics.DebuggerNonUserCodeAttribute] |
|
||||||
public void MergeFrom(pb::CodedInputStream input) { |
|
||||||
uint tag; |
|
||||||
while ((tag = input.ReadTag()) != 0) { |
|
||||||
switch(tag) { |
|
||||||
default: |
|
||||||
_unknownFields = pb::UnknownFieldSet.MergeFieldFrom(_unknownFields, input); |
|
||||||
break; |
|
||||||
case 8: { |
|
||||||
Count = input.ReadInt64(); |
|
||||||
break; |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
|
|
||||||
#endregion |
|
||||||
|
|
||||||
} |
|
||||||
|
|
||||||
#endregion Designer generated code |
|
||||||
@ -1,208 +0,0 @@ |
|||||||
// <auto-generated> |
|
||||||
// Generated by the protocol buffer compiler. DO NOT EDIT! |
|
||||||
// source: math_with_protoc_options.proto |
|
||||||
// </auto-generated> |
|
||||||
// Original file comments: |
|
||||||
// Copyright 2015 gRPC authors. |
|
||||||
// |
|
||||||
// Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
// you may not use this file except in compliance with the License. |
|
||||||
// You may obtain a copy of the License at |
|
||||||
// |
|
||||||
// http://www.apache.org/licenses/LICENSE-2.0 |
|
||||||
// |
|
||||||
// Unless required by applicable law or agreed to in writing, software |
|
||||||
// distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
// See the License for the specific language governing permissions and |
|
||||||
// limitations under the License. |
|
||||||
// |
|
||||||
#pragma warning disable 0414, 1591 |
|
||||||
#region Designer generated code |
|
||||||
|
|
||||||
using grpc = global::Grpc.Core; |
|
||||||
|
|
||||||
namespace MathWithProtocOptions { |
|
||||||
public static partial class Math |
|
||||||
{ |
|
||||||
static readonly string __ServiceName = "math_with_protoc_options.Math"; |
|
||||||
|
|
||||||
static readonly grpc::Marshaller<global::MathWithProtocOptions.DivArgs> __Marshaller_math_with_protoc_options_DivArgs = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::MathWithProtocOptions.DivArgs.Parser.ParseFrom); |
|
||||||
static readonly grpc::Marshaller<global::MathWithProtocOptions.DivReply> __Marshaller_math_with_protoc_options_DivReply = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::MathWithProtocOptions.DivReply.Parser.ParseFrom); |
|
||||||
static readonly grpc::Marshaller<global::MathWithProtocOptions.FibArgs> __Marshaller_math_with_protoc_options_FibArgs = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::MathWithProtocOptions.FibArgs.Parser.ParseFrom); |
|
||||||
static readonly grpc::Marshaller<global::MathWithProtocOptions.Num> __Marshaller_math_with_protoc_options_Num = grpc::Marshallers.Create((arg) => global::Google.Protobuf.MessageExtensions.ToByteArray(arg), global::MathWithProtocOptions.Num.Parser.ParseFrom); |
|
||||||
|
|
||||||
static readonly grpc::Method<global::MathWithProtocOptions.DivArgs, global::MathWithProtocOptions.DivReply> __Method_Div = new grpc::Method<global::MathWithProtocOptions.DivArgs, global::MathWithProtocOptions.DivReply>( |
|
||||||
grpc::MethodType.Unary, |
|
||||||
__ServiceName, |
|
||||||
"Div", |
|
||||||
__Marshaller_math_with_protoc_options_DivArgs, |
|
||||||
__Marshaller_math_with_protoc_options_DivReply); |
|
||||||
|
|
||||||
static readonly grpc::Method<global::MathWithProtocOptions.DivArgs, global::MathWithProtocOptions.DivReply> __Method_DivMany = new grpc::Method<global::MathWithProtocOptions.DivArgs, global::MathWithProtocOptions.DivReply>( |
|
||||||
grpc::MethodType.DuplexStreaming, |
|
||||||
__ServiceName, |
|
||||||
"DivMany", |
|
||||||
__Marshaller_math_with_protoc_options_DivArgs, |
|
||||||
__Marshaller_math_with_protoc_options_DivReply); |
|
||||||
|
|
||||||
static readonly grpc::Method<global::MathWithProtocOptions.FibArgs, global::MathWithProtocOptions.Num> __Method_Fib = new grpc::Method<global::MathWithProtocOptions.FibArgs, global::MathWithProtocOptions.Num>( |
|
||||||
grpc::MethodType.ServerStreaming, |
|
||||||
__ServiceName, |
|
||||||
"Fib", |
|
||||||
__Marshaller_math_with_protoc_options_FibArgs, |
|
||||||
__Marshaller_math_with_protoc_options_Num); |
|
||||||
|
|
||||||
static readonly grpc::Method<global::MathWithProtocOptions.Num, global::MathWithProtocOptions.Num> __Method_Sum = new grpc::Method<global::MathWithProtocOptions.Num, global::MathWithProtocOptions.Num>( |
|
||||||
grpc::MethodType.ClientStreaming, |
|
||||||
__ServiceName, |
|
||||||
"Sum", |
|
||||||
__Marshaller_math_with_protoc_options_Num, |
|
||||||
__Marshaller_math_with_protoc_options_Num); |
|
||||||
|
|
||||||
/// <summary>Service descriptor</summary> |
|
||||||
public static global::Google.Protobuf.Reflection.ServiceDescriptor Descriptor |
|
||||||
{ |
|
||||||
get { return global::MathWithProtocOptions.MathWithProtocOptionsReflection.Descriptor.Services[0]; } |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary>Lite client for Math</summary> |
|
||||||
public partial class MathClient : grpc::LiteClientBase |
|
||||||
{ |
|
||||||
/// <summary>Creates a new client for Math that uses a custom <c>CallInvoker</c>.</summary> |
|
||||||
/// <param name="callInvoker">The callInvoker to use to make remote calls.</param> |
|
||||||
public MathClient(grpc::CallInvoker callInvoker) : base(callInvoker) |
|
||||||
{ |
|
||||||
} |
|
||||||
/// <summary>Protected parameterless constructor to allow creation of test doubles.</summary> |
|
||||||
protected MathClient() : base() |
|
||||||
{ |
|
||||||
} |
|
||||||
|
|
||||||
/// <summary> |
|
||||||
/// Div divides DivArgs.dividend by DivArgs.divisor and returns the quotient |
|
||||||
/// and remainder. |
|
||||||
/// </summary> |
|
||||||
/// <param name="request">The request to send to the server.</param> |
|
||||||
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> |
|
||||||
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> |
|
||||||
/// <param name="cancellationToken">An optional token for canceling the call.</param> |
|
||||||
/// <returns>The response received from the server.</returns> |
|
||||||
public virtual global::MathWithProtocOptions.DivReply Div(global::MathWithProtocOptions.DivArgs request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) |
|
||||||
{ |
|
||||||
return Div(request, new grpc::CallOptions(headers, deadline, cancellationToken)); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// Div divides DivArgs.dividend by DivArgs.divisor and returns the quotient |
|
||||||
/// and remainder. |
|
||||||
/// </summary> |
|
||||||
/// <param name="request">The request to send to the server.</param> |
|
||||||
/// <param name="options">The options for the call.</param> |
|
||||||
/// <returns>The response received from the server.</returns> |
|
||||||
public virtual global::MathWithProtocOptions.DivReply Div(global::MathWithProtocOptions.DivArgs request, grpc::CallOptions options) |
|
||||||
{ |
|
||||||
return CallInvoker.BlockingUnaryCall(__Method_Div, null, options, request); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// Div divides DivArgs.dividend by DivArgs.divisor and returns the quotient |
|
||||||
/// and remainder. |
|
||||||
/// </summary> |
|
||||||
/// <param name="request">The request to send to the server.</param> |
|
||||||
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> |
|
||||||
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> |
|
||||||
/// <param name="cancellationToken">An optional token for canceling the call.</param> |
|
||||||
/// <returns>The call object.</returns> |
|
||||||
public virtual grpc::AsyncUnaryCall<global::MathWithProtocOptions.DivReply> DivAsync(global::MathWithProtocOptions.DivArgs request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) |
|
||||||
{ |
|
||||||
return DivAsync(request, new grpc::CallOptions(headers, deadline, cancellationToken)); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// Div divides DivArgs.dividend by DivArgs.divisor and returns the quotient |
|
||||||
/// and remainder. |
|
||||||
/// </summary> |
|
||||||
/// <param name="request">The request to send to the server.</param> |
|
||||||
/// <param name="options">The options for the call.</param> |
|
||||||
/// <returns>The call object.</returns> |
|
||||||
public virtual grpc::AsyncUnaryCall<global::MathWithProtocOptions.DivReply> DivAsync(global::MathWithProtocOptions.DivArgs request, grpc::CallOptions options) |
|
||||||
{ |
|
||||||
return CallInvoker.AsyncUnaryCall(__Method_Div, null, options, request); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// DivMany accepts an arbitrary number of division args from the client stream |
|
||||||
/// and sends back the results in the reply stream. The stream continues until |
|
||||||
/// the client closes its end; the server does the same after sending all the |
|
||||||
/// replies. The stream ends immediately if either end aborts. |
|
||||||
/// </summary> |
|
||||||
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> |
|
||||||
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> |
|
||||||
/// <param name="cancellationToken">An optional token for canceling the call.</param> |
|
||||||
/// <returns>The call object.</returns> |
|
||||||
public virtual grpc::AsyncDuplexStreamingCall<global::MathWithProtocOptions.DivArgs, global::MathWithProtocOptions.DivReply> DivMany(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) |
|
||||||
{ |
|
||||||
return DivMany(new grpc::CallOptions(headers, deadline, cancellationToken)); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// DivMany accepts an arbitrary number of division args from the client stream |
|
||||||
/// and sends back the results in the reply stream. The stream continues until |
|
||||||
/// the client closes its end; the server does the same after sending all the |
|
||||||
/// replies. The stream ends immediately if either end aborts. |
|
||||||
/// </summary> |
|
||||||
/// <param name="options">The options for the call.</param> |
|
||||||
/// <returns>The call object.</returns> |
|
||||||
public virtual grpc::AsyncDuplexStreamingCall<global::MathWithProtocOptions.DivArgs, global::MathWithProtocOptions.DivReply> DivMany(grpc::CallOptions options) |
|
||||||
{ |
|
||||||
return CallInvoker.AsyncDuplexStreamingCall(__Method_DivMany, null, options); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// Fib generates numbers in the Fibonacci sequence. If FibArgs.limit > 0, Fib |
|
||||||
/// generates up to limit numbers; otherwise it continues until the call is |
|
||||||
/// canceled. Unlike Fib above, Fib has no final FibReply. |
|
||||||
/// </summary> |
|
||||||
/// <param name="request">The request to send to the server.</param> |
|
||||||
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> |
|
||||||
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> |
|
||||||
/// <param name="cancellationToken">An optional token for canceling the call.</param> |
|
||||||
/// <returns>The call object.</returns> |
|
||||||
public virtual grpc::AsyncServerStreamingCall<global::MathWithProtocOptions.Num> Fib(global::MathWithProtocOptions.FibArgs request, grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) |
|
||||||
{ |
|
||||||
return Fib(request, new grpc::CallOptions(headers, deadline, cancellationToken)); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// Fib generates numbers in the Fibonacci sequence. If FibArgs.limit > 0, Fib |
|
||||||
/// generates up to limit numbers; otherwise it continues until the call is |
|
||||||
/// canceled. Unlike Fib above, Fib has no final FibReply. |
|
||||||
/// </summary> |
|
||||||
/// <param name="request">The request to send to the server.</param> |
|
||||||
/// <param name="options">The options for the call.</param> |
|
||||||
/// <returns>The call object.</returns> |
|
||||||
public virtual grpc::AsyncServerStreamingCall<global::MathWithProtocOptions.Num> Fib(global::MathWithProtocOptions.FibArgs request, grpc::CallOptions options) |
|
||||||
{ |
|
||||||
return CallInvoker.AsyncServerStreamingCall(__Method_Fib, null, options, request); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// Sum sums a stream of numbers, returning the final result once the stream |
|
||||||
/// is closed. |
|
||||||
/// </summary> |
|
||||||
/// <param name="headers">The initial metadata to send with the call. This parameter is optional.</param> |
|
||||||
/// <param name="deadline">An optional deadline for the call. The call will be cancelled if deadline is hit.</param> |
|
||||||
/// <param name="cancellationToken">An optional token for canceling the call.</param> |
|
||||||
/// <returns>The call object.</returns> |
|
||||||
public virtual grpc::AsyncClientStreamingCall<global::MathWithProtocOptions.Num, global::MathWithProtocOptions.Num> Sum(grpc::Metadata headers = null, global::System.DateTime? deadline = null, global::System.Threading.CancellationToken cancellationToken = default(global::System.Threading.CancellationToken)) |
|
||||||
{ |
|
||||||
return Sum(new grpc::CallOptions(headers, deadline, cancellationToken)); |
|
||||||
} |
|
||||||
/// <summary> |
|
||||||
/// Sum sums a stream of numbers, returning the final result once the stream |
|
||||||
/// is closed. |
|
||||||
/// </summary> |
|
||||||
/// <param name="options">The options for the call.</param> |
|
||||||
/// <returns>The call object.</returns> |
|
||||||
public virtual grpc::AsyncClientStreamingCall<global::MathWithProtocOptions.Num, global::MathWithProtocOptions.Num> Sum(grpc::CallOptions options) |
|
||||||
{ |
|
||||||
return CallInvoker.AsyncClientStreamingCall(__Method_Sum, null, options); |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
} |
|
||||||
} |
|
||||||
#endregion |
|
||||||
@ -1,65 +0,0 @@ |
|||||||
|
|
||||||
// Copyright 2015 gRPC authors. |
|
||||||
// |
|
||||||
// Licensed under the Apache License, Version 2.0 (the "License"); |
|
||||||
// you may not use this file except in compliance with the License. |
|
||||||
// You may obtain a copy of the License at |
|
||||||
// |
|
||||||
// http://www.apache.org/licenses/LICENSE-2.0 |
|
||||||
// |
|
||||||
// Unless required by applicable law or agreed to in writing, software |
|
||||||
// distributed under the License is distributed on an "AS IS" BASIS, |
|
||||||
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
|
||||||
// See the License for the specific language governing permissions and |
|
||||||
// limitations under the License. |
|
||||||
|
|
||||||
syntax = "proto3"; |
|
||||||
|
|
||||||
package math_with_protoc_options; |
|
||||||
|
|
||||||
message DivArgs { |
|
||||||
int64 dividend = 1; |
|
||||||
int64 divisor = 2; |
|
||||||
} |
|
||||||
|
|
||||||
message DivReply { |
|
||||||
int64 quotient = 1; |
|
||||||
int64 remainder = 2; |
|
||||||
} |
|
||||||
|
|
||||||
message FibArgs { |
|
||||||
int64 limit = 1; |
|
||||||
} |
|
||||||
|
|
||||||
message Num { |
|
||||||
int64 num = 1; |
|
||||||
} |
|
||||||
|
|
||||||
message FibReply { |
|
||||||
int64 count = 1; |
|
||||||
} |
|
||||||
|
|
||||||
service Math { |
|
||||||
// Div divides DivArgs.dividend by DivArgs.divisor and returns the quotient |
|
||||||
// and remainder. |
|
||||||
rpc Div (DivArgs) returns (DivReply) { |
|
||||||
} |
|
||||||
|
|
||||||
// DivMany accepts an arbitrary number of division args from the client stream |
|
||||||
// and sends back the results in the reply stream. The stream continues until |
|
||||||
// the client closes its end; the server does the same after sending all the |
|
||||||
// replies. The stream ends immediately if either end aborts. |
|
||||||
rpc DivMany (stream DivArgs) returns (stream DivReply) { |
|
||||||
} |
|
||||||
|
|
||||||
// Fib generates numbers in the Fibonacci sequence. If FibArgs.limit > 0, Fib |
|
||||||
// generates up to limit numbers; otherwise it continues until the call is |
|
||||||
// canceled. Unlike Fib above, Fib has no final FibReply. |
|
||||||
rpc Fib (FibArgs) returns (stream Num) { |
|
||||||
} |
|
||||||
|
|
||||||
// Sum sums a stream of numbers, returning the final result once the stream |
|
||||||
// is closed. |
|
||||||
rpc Sum (stream Num) returns (Num) { |
|
||||||
} |
|
||||||
} |
|
||||||
@ -1 +1 @@ |
|||||||
Subproject commit e776aa0275e293707b6a0901e0e8d8a8a3679508 |
Subproject commit 090faecb454fbd6e6e17a75ef8146acb037118d4 |
||||||
Loading…
Reference in new issue