Home
last modified time | relevance | path

Searched refs:CallInvoker (Results 1 – 25 of 27) sorted by relevance

12

/third_party/grpc/src/csharp/Grpc.Core.Api/
DClientBase.cs62 public ClientBase(CallInvoker callInvoker) : base(callInvoker) in ClientBase()
90 readonly CallInvoker callInvoker;
124 … public ClientBase(CallInvoker callInvoker) : this(new ClientBaseConfiguration(callInvoker, null)) in ClientBase()
131 protected CallInvoker CallInvoker property in Grpc.Core.ClientBase
210 readonly CallInvoker undecoratedCallInvoker;
213 internal ClientBaseConfiguration(CallInvoker undecoratedCallInvoker, string host) in ClientBaseConfiguration()
219 internal CallInvoker CreateDecoratedCallInvoker() in CreateDecoratedCallInvoker()
DChannelBase.cs51 public abstract CallInvoker CreateCallInvoker(); in CreateCallInvoker()
DCallInvoker.cs26 public abstract class CallInvoker class
/third_party/grpc/src/csharp/Grpc.Core.Api/Interceptors/
DCallInvokerExtensions.cs43 public static CallInvoker Intercept(this CallInvoker invoker, Interceptor interceptor) in Intercept()
64 … public static CallInvoker Intercept(this CallInvoker invoker, params Interceptor[] interceptors) in Intercept()
92 …public static CallInvoker Intercept(this CallInvoker invoker, Func<Metadata, Metadata> interceptor) in Intercept()
DChannelExtensions.cs41 public static CallInvoker Intercept(this ChannelBase channel, Interceptor interceptor) in Intercept()
62 … public static CallInvoker Intercept(this ChannelBase channel, params Interceptor[] interceptors) in Intercept()
82 …public static CallInvoker Intercept(this ChannelBase channel, Func<Metadata, Metadata> interceptor) in Intercept()
DInterceptingCallInvoker.cs28 internal class InterceptingCallInvoker : CallInvoker
30 readonly CallInvoker invoker;
37 public InterceptingCallInvoker(CallInvoker invoker, Interceptor interceptor) in InterceptingCallInvoker()
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DTestGrpc.cs254 public TestServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) in TestServiceClient()
287 return CallInvoker.BlockingUnaryCall(__Method_EmptyCall, null, options, request); in EmptyCall()
309 return CallInvoker.AsyncUnaryCall(__Method_EmptyCall, null, options, request); in EmptyCallAsync()
331 return CallInvoker.BlockingUnaryCall(__Method_UnaryCall, null, options, request); in UnaryCall()
353 return CallInvoker.AsyncUnaryCall(__Method_UnaryCall, null, options, request); in UnaryCallAsync()
379 return CallInvoker.BlockingUnaryCall(__Method_CacheableUnaryCall, null, options, request); in CacheableUnaryCall()
405 return CallInvoker.AsyncUnaryCall(__Method_CacheableUnaryCall, null, options, request); in CacheableUnaryCallAsync()
429 … return CallInvoker.AsyncServerStreamingCall(__Method_StreamingOutputCall, null, options, request); in StreamingOutputCall()
451 return CallInvoker.AsyncClientStreamingCall(__Method_StreamingInputCall, null, options); in StreamingInputCall()
475 return CallInvoker.AsyncDuplexStreamingCall(__Method_FullDuplexCall, null, options); in FullDuplexCall()
[all …]
DBenchmarkServiceGrpc.cs186 public BenchmarkServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) in BenchmarkServiceClient()
221 return CallInvoker.BlockingUnaryCall(__Method_UnaryCall, null, options, request); in UnaryCall()
245 return CallInvoker.AsyncUnaryCall(__Method_UnaryCall, null, options, request); in UnaryCallAsync()
269 return CallInvoker.AsyncDuplexStreamingCall(__Method_StreamingCall, null, options); in StreamingCall()
291 return CallInvoker.AsyncClientStreamingCall(__Method_StreamingFromClient, null, options); in StreamingFromClient()
315 … return CallInvoker.AsyncServerStreamingCall(__Method_StreamingFromServer, null, options, request); in StreamingFromServer()
337 return CallInvoker.AsyncDuplexStreamingCall(__Method_StreamingBothWays, null, options); in StreamingBothWays()
DWorkerServiceGrpc.cs176 public WorkerServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) in WorkerServiceClient()
217 return CallInvoker.AsyncDuplexStreamingCall(__Method_RunServer, null, options); in RunServer()
247 return CallInvoker.AsyncDuplexStreamingCall(__Method_RunClient, null, options); in RunClient()
269 return CallInvoker.BlockingUnaryCall(__Method_CoreCount, null, options, request); in CoreCount()
291 return CallInvoker.AsyncUnaryCall(__Method_CoreCount, null, options, request); in CoreCountAsync()
313 return CallInvoker.BlockingUnaryCall(__Method_QuitWorker, null, options, request); in QuitWorker()
335 return CallInvoker.AsyncUnaryCall(__Method_QuitWorker, null, options, request); in QuitWorkerAsync()
DMetricsGrpc.cs130 public MetricsServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) in MetricsServiceClient()
165 return CallInvoker.AsyncServerStreamingCall(__Method_GetAllGauges, null, options, request); in GetAllGauges()
187 return CallInvoker.BlockingUnaryCall(__Method_GetGauge, null, options, request); in GetGauge()
209 return CallInvoker.AsyncUnaryCall(__Method_GetGauge, null, options, request); in GetGaugeAsync()
DReportQpsScenarioServiceGrpc.cs105 public ReportQpsScenarioServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) in ReportQpsScenarioServiceClient()
138 return CallInvoker.BlockingUnaryCall(__Method_ReportScenario, null, options, request); in ReportScenario()
160 return CallInvoker.AsyncUnaryCall(__Method_ReportScenario, null, options, request); in ReportScenarioAsync()
DEmptyServiceGrpc.cs57 public EmptyServiceClient(grpc::CallInvoker callInvoker) : base(callInvoker) in EmptyServiceClient()
/third_party/grpc/src/csharp/Grpc.Microbenchmarks/
DPingBenchmark.cs91 public PingClient(CallInvoker callInvoker) : base(callInvoker) { } in PingClient()
94 return CallInvoker.AsyncUnaryCall(PingMethod, null, options, request); in PingAsync()
98 return CallInvoker.BlockingUnaryCall(PingMethod, null, options, request); in Ping()
DUnaryCallOverheadBenchmark.cs96 public PingClient(CallInvoker callInvoker) : base(callInvoker) { } in PingClient()
100 return CallInvoker.BlockingUnaryCall(PingMethod, null, options, request); in Ping()
/third_party/grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs168 public MathClient(grpc::CallInvoker callInvoker) : base(callInvoker) in MathClient()
203 return CallInvoker.BlockingUnaryCall(__Method_Div, null, options, request); in Div()
227 return CallInvoker.AsyncUnaryCall(__Method_Div, null, options, request); in DivAsync()
253 return CallInvoker.AsyncDuplexStreamingCall(__Method_DivMany, null, options); in DivMany()
279 return CallInvoker.AsyncServerStreamingCall(__Method_Fib, null, options, request); in Fib()
301 return CallInvoker.AsyncClientStreamingCall(__Method_Sum, null, options); in Sum()
/third_party/grpc/examples/csharp/HelloworldUnity/Assets/Scripts/
DHelloworldGrpc.cs76 public GreeterClient(grpc::CallInvoker callInvoker) : base(callInvoker) in GreeterClient()
109 return CallInvoker.BlockingUnaryCall(__Method_SayHello, null, options, request); in SayHello()
131 return CallInvoker.AsyncUnaryCall(__Method_SayHello, null, options, request); in SayHelloAsync()
/third_party/grpc/examples/csharp/HelloworldXamarin/HelloworldXamarin/
DHelloworldGrpc.cs76 public GreeterClient(grpc::CallInvoker callInvoker) : base(callInvoker) in GreeterClient()
109 return CallInvoker.BlockingUnaryCall(__Method_SayHello, null, options, request); in SayHello()
131 return CallInvoker.AsyncUnaryCall(__Method_SayHello, null, options, request); in SayHelloAsync()
/third_party/grpc/src/csharp/Grpc.HealthCheck/
DHealthGrpc.cs140 public HealthClient(grpc::CallInvoker callInvoker) : base(callInvoker) in HealthClient()
175 return CallInvoker.BlockingUnaryCall(__Method_Check, null, options, request); in Check()
199 return CallInvoker.AsyncUnaryCall(__Method_Check, null, options, request); in CheckAsync()
249 return CallInvoker.AsyncServerStreamingCall(__Method_Watch, null, options, request); in Watch()
/third_party/grpc/src/php/tests/unit_tests/
DCallInvokerTest.php82 class CallInvokerUpdateChannel implements \Grpc\CallInvoker
113 class CallInvokerChangeRequest implements \Grpc\CallInvoker
/third_party/grpc/src/csharp/Grpc.Reflection/
DReflectionGrpc.cs107 public ServerReflectionClient(grpc::CallInvoker callInvoker) : base(callInvoker) in ServerReflectionClient()
140 return CallInvoker.AsyncDuplexStreamingCall(__Method_ServerReflectionInfo, null, options); in ServerReflectionInfo()
/third_party/grpc/src/php/lib/Grpc/
DCallInvoker.php26 interface CallInvoker interface
DDefaultCallInvoker.php25 class DefaultCallInvoker implements CallInvoker
/third_party/grpc/src/csharp/Grpc.Core/Internal/
DUnimplementedCallInvoker.cs29 internal class UnimplementedCallInvoker : CallInvoker
/third_party/grpc/src/csharp/Grpc.Core.Api/Internal/
DUnimplementedCallInvoker.cs29 internal class UnimplementedCallInvoker : CallInvoker
/third_party/grpc/src/csharp/Grpc.Core/
DDefaultCallInvoker.cs28 public class DefaultCallInvoker : CallInvoker

12