Home
last modified time | relevance | path

Searched refs:AsyncClientStreamingCall (Results 1 – 23 of 23) sorted by relevance

/third_party/grpc/src/csharp/Grpc.Core.Api/Interceptors/
DInterceptingCallInvoker.cs79 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.Interceptors.InterceptingCallInvoker
81 return interceptor.AsyncClientStreamingCall( in AsyncClientStreamingCall()
83 ctx => invoker.AsyncClientStreamingCall(ctx.Method, ctx.Host, ctx.Options)); in AsyncClientStreamingCall()
DInterceptor.cs129 …public delegate AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCallContinuation…
259 …public virtual AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TR…
DCallInvokerExtensions.cs132 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.Interceptors.CallInvokerExtensions.MetadataInterceptor
/third_party/grpc/src/csharp/Grpc.Core.Api/
DAsyncClientStreamingCall.cs30 public sealed class AsyncClientStreamingCall<TRequest, TResponse> : IDisposable class
45 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall() method in Grpc.Core.AsyncClientStreamingCall
67 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall() method in Grpc.Core.AsyncClientStreamingCall
DCallInvoker.cs54 …public abstract AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T…
DClientBase.cs187 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.ClientBase.ClientBaseConfiguration.ClientBaseConfigurationInterceptor
/third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DClientInterceptorTest.cs125 …var call = callInvoker.AsyncClientStreamingCall(new Method<string, string>(MethodType.ClientStream… in CountNumberOfRequestsInClientInterceptors()
160 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.CallbackInterceptor
175 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.ClientStreamingCountingInterceptor
184 …return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, responseAsync, response.Re… in AsyncClientStreamingCall()
/third_party/grpc/src/csharp/Grpc.Core.Testing/
DTestCalls.cs45 …public static AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRe… in AsyncClientStreamingCall() method in Grpc.Core.Testing.TestCalls
50 …return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, responseAsync, responseHea… in AsyncClientStreamingCall()
/third_party/grpc/src/csharp/Grpc.Core/
DDefaultCallInvoker.cs73 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.DefaultCallInvoker
76 return Calls.AsyncClientStreamingCall(call); in AsyncClientStreamingCall()
DCalls.cs99 …public static AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRe…
106 return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, resultTask,
DForwardedTypes.cs29 [assembly:TypeForwardedToAttribute(typeof(AsyncClientStreamingCall<,>))]
/third_party/grpc/src/csharp/Grpc.Core/Internal/
DUnimplementedCallInvoker.cs50 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/third_party/grpc/src/csharp/Grpc.Core.Api/Internal/
DUnimplementedCallInvoker.cs50 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/third_party/grpc/src/csharp/Grpc.Core.Tests/
DCallCancellationTest.cs70 …var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(cancell… in ClientStreamingCall_CancelAfterBegin()
108 …var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(cancell… in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
137 var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall()); in ClientStreamingCall_CancelServerSideRead()
DContextPropagationTest.cs90 …var parentCall = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(c… in PropagateCancellation()
130 …var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(deadlin… in PropagateDeadline()
153 …var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall(new CallOptions(deadlin… in SuppressDeadlinePropagation()
DMarshallingErrorsTest.cs134 var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall()); in RequestParsingError_StreamingRequest()
160 var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall()); in RequestSerializationError_ClientStreaming()
DHalfcloseTest.cs70 var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall()); in HalfcloseAfterFullclose_ClientStreamingCall()
DResponseHeadersTest.cs92 var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall()); in ResponseHeadersAsync_ClientStreamingCall()
DClientServerTest.cs200 var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall()); in ClientStreamingCall()
/third_party/grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs289 …public virtual grpc::AsyncClientStreamingCall<global::Math.Num, global::Math.Num> Sum(grpc::Metada… in Sum()
299 …public virtual grpc::AsyncClientStreamingCall<global::Math.Num, global::Math.Num> Sum(grpc::CallOp… in Sum()
301 return CallInvoker.AsyncClientStreamingCall(__Method_Sum, null, options); in Sum()
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DBenchmarkServiceGrpc.cs279 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingFromClient()
289 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingFromClient()
291 return CallInvoker.AsyncClientStreamingCall(__Method_StreamingFromClient, null, options); in StreamingFromClient()
DTestGrpc.cs439 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, glob… in StreamingInputCall()
449 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, glob… in StreamingInputCall()
451 return CallInvoker.AsyncClientStreamingCall(__Method_StreamingInputCall, null, options); in StreamingInputCall()
/third_party/grpc/src/csharp/Grpc.Examples.Tests/
DMathClientMockableTest.cs71 …var fakeCall = TestCalls.AsyncClientStreamingCall<Num, Num>(mockRequestStream.Object, Task.FromRes… in ClientBaseClientStreamingCallCanBeMocked()