Home
last modified time | relevance | path

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

/external/grpc-grpc/src/csharp/Grpc.Core/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
/external/grpc-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()
/external/grpc-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()
/external/grpc-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.cs92 …public static AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, TRe…
99 …return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, resultTask, asyncCall.Resp…
DAsyncClientStreamingCall.cs30 public sealed class AsyncClientStreamingCall<TRequest, TResponse> : IDisposable class
48 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall() method in Grpc.Core.AsyncClientStreamingCall
DCallInvoker.cs56 …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
/external/grpc-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.cs180 var call = Calls.AsyncClientStreamingCall(helper.CreateClientStreamingCall()); in ClientStreamingCall()
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DUnimplementedCallInvoker.cs50 …public override AsyncClientStreamingCall<TRequest, TResponse> AsyncClientStreamingCall<TRequest, T… in AsyncClientStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs258 …public virtual grpc::AsyncClientStreamingCall<global::Math.Num, global::Math.Num> Sum(grpc::Metada… in Sum()
268 …public virtual grpc::AsyncClientStreamingCall<global::Math.Num, global::Math.Num> Sum(grpc::CallOp… in Sum()
270 return CallInvoker.AsyncClientStreamingCall(__Method_Sum, null, options); in Sum()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/
DRouteGuideGrpc.cs269 …public virtual grpc::AsyncClientStreamingCall<global::Routeguide.Point, global::Routeguide.RouteSu… in RecordRoute()
281 …public virtual grpc::AsyncClientStreamingCall<global::Routeguide.Point, global::Routeguide.RouteSu… in RecordRoute()
283 return CallInvoker.AsyncClientStreamingCall(__Method_RecordRoute, null, options); in RecordRoute()
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DBenchmarkServiceGrpc.cs248 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingFromClient()
258 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingFromClient()
260 return CallInvoker.AsyncClientStreamingCall(__Method_StreamingFromClient, null, options); in StreamingFromClient()
DTestGrpc.cs408 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, glob… in StreamingInputCall()
418 …public virtual grpc::AsyncClientStreamingCall<global::Grpc.Testing.StreamingInputCallRequest, glob… in StreamingInputCall()
420 return CallInvoker.AsyncClientStreamingCall(__Method_StreamingInputCall, null, options); in StreamingInputCall()
/external/grpc-grpc/src/csharp/Grpc.Examples.Tests/
DMathClientMockableTest.cs71 …var fakeCall = TestCalls.AsyncClientStreamingCall<Num, Num>(mockRequestStream.Object, Task.FromRes… in ClientBaseClientStreamingCallCanBeMocked()