| /third_party/grpc/src/csharp/Grpc.Core.Api/Interceptors/ |
| D | InterceptingCallInvoker.cs | 68 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.Interceptors.InterceptingCallInvoker
70 return interceptor.AsyncServerStreamingCall( in AsyncServerStreamingCall()
73 … (req, ctx) => invoker.AsyncServerStreamingCall(ctx.Method, ctx.Host, ctx.Options, req)); in AsyncServerStreamingCall()
|
| D | Interceptor.cs | 104 …public delegate AsyncServerStreamingCall<TResponse> AsyncServerStreamingCallContinuation<TRequest,…
232 …public virtual AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(T…
|
| D | CallInvokerExtensions.cs | 127 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.Interceptors.CallInvokerExtensions.MetadataInterceptor
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | AsyncServerStreamingCall.cs | 28 public sealed class AsyncServerStreamingCall<TResponse> : IDisposable class
41 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall() method in Grpc.Core.AsyncServerStreamingCall
60 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall() method in Grpc.Core.AsyncServerStreamingCall
|
| D | CallInvoker.cs | 46 …public abstract AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(…
|
| D | ClientBase.cs | 182 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.ClientBase.ClientBaseConfiguration.ClientBaseConfigurationInterceptor
|
| /third_party/grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestCalls.cs | 57 public static AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TResponse>( in AsyncServerStreamingCall() method in Grpc.Core.Testing.TestCalls
61 …return new AsyncServerStreamingCall<TResponse>(responseStream, responseHeadersAsync, getStatusFunc… in AsyncServerStreamingCall()
|
| /third_party/grpc/src/csharp/Grpc.Core/ |
| D | DefaultCallInvoker.cs | 63 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.DefaultCallInvoker
66 return Calls.AsyncServerStreamingCall(call, request); in AsyncServerStreamingCall()
|
| D | Calls.cs | 78 …public static AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(Ca…
85 return new AsyncServerStreamingCall<TResponse>(responseStream,
|
| D | ForwardedTypes.cs | 31 [assembly:TypeForwardedToAttribute(typeof(AsyncServerStreamingCall<>))]
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | UnimplementedCallInvoker.cs | 45 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/Internal/ |
| D | UnimplementedCallInvoker.cs | 45 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
|
| /third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | MetricsGrpc.cs | 152 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(glo… in GetAllGauges()
163 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(glo… in GetAllGauges()
165 return CallInvoker.AsyncServerStreamingCall(__Method_GetAllGauges, null, options, request); in GetAllGauges()
|
| D | BenchmarkServiceGrpc.cs | 302 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.SimpleResponse> StreamingFromSe… in StreamingFromServer()
313 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.SimpleResponse> StreamingFromSe… in StreamingFromServer()
315 … return CallInvoker.AsyncServerStreamingCall(__Method_StreamingFromServer, null, options, request); in StreamingFromServer()
|
| D | TestGrpc.cs | 416 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.StreamingOutputCallResponse> St… in StreamingOutputCall()
427 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.StreamingOutputCallResponse> St… in StreamingOutputCall()
429 … return CallInvoker.AsyncServerStreamingCall(__Method_StreamingOutputCall, null, options, request); in StreamingOutputCall()
|
| /third_party/grpc/src/csharp/Grpc.HealthCheck/ |
| D | HealthGrpc.cs | 223 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Health.V1.HealthCheckResponse> Watch(gl… in Watch()
247 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Health.V1.HealthCheckResponse> Watch(gl… in Watch()
249 return CallInvoker.AsyncServerStreamingCall(__Method_Watch, null, options, request); in Watch()
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/ |
| D | ResponseHeadersTest.cs | 109 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ResponseHeadersAsync_ServerStreamingCall()
187 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in WriteResponseHeaders_NotAllowedAfterWrite()
|
| D | ClientServerTest.cs | 217 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), "A B C"); in ServerStreamingCall()
229 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ServerStreamingCall_EndOfStreamIsIdempotent()
244 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ServerStreamingCall_ErrorCanBeAwaitedTwice()
263 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ServerStreamingCall_TrailersFromMultipleSourcesGetConcatenated()
|
| D | MarshallingErrorsTest.cs | 99 … var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), "REQUEST"); in ResponseParsingError_StreamingResponse()
|
| D | CallCancellationTest.cs | 162 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ServerStreamingCall_CancelClientSideRead()
|
| /third_party/grpc/src/csharp/Grpc.Examples/ |
| D | MathGrpc.cs | 265 …public virtual grpc::AsyncServerStreamingCall<global::Math.Num> Fib(global::Math.FibArgs request, … in Fib()
277 …public virtual grpc::AsyncServerStreamingCall<global::Math.Num> Fib(global::Math.FibArgs request, … in Fib()
279 return CallInvoker.AsyncServerStreamingCall(__Method_Fib, null, options, request); in Fib()
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ClientInterceptorTest.cs | 154 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.CallbackInterceptor
|
| /third_party/grpc/src/csharp/Grpc.Examples.Tests/ |
| D | MathClientMockableTest.cs | 83 …var fakeCall = TestCalls.AsyncServerStreamingCall<Num>(mockResponseStream.Object, Task.FromResult(… in ClientBaseServerStreamingCallCanBeMocked()
|