Home
last modified time | relevance | path

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

/external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/
DInterceptingCallInvoker.cs89 …public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T… in AsyncDuplexStreamingCall() method in Grpc.Core.Interceptors.InterceptingCallInvoker
91 return interceptor.AsyncDuplexStreamingCall( in AsyncDuplexStreamingCall()
93 ctx => invoker.AsyncDuplexStreamingCall(ctx.Method, ctx.Host, ctx.Options)); in AsyncDuplexStreamingCall()
DInterceptor.cs152 …public delegate AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCallContinuation…
286 …public virtual AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TR…
DCallInvokerExtensions.cs137 …public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T… in AsyncDuplexStreamingCall() method in Grpc.Core.Interceptors.CallInvokerExtensions.MetadataInterceptor
/external/grpc-grpc/src/csharp/Grpc.Core.Testing/
DTestCalls.cs68 …public static AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRe… in AsyncDuplexStreamingCall() method in Grpc.Core.Testing.TestCalls
73 …return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, responseHe… in AsyncDuplexStreamingCall()
/external/grpc-grpc/src/csharp/Grpc.Core/
DDefaultCallInvoker.cs84 …public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T… in AsyncDuplexStreamingCall() method in Grpc.Core.DefaultCallInvoker
87 return Calls.AsyncDuplexStreamingCall(call); in AsyncDuplexStreamingCall()
DCalls.cs111 …public static AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRe…
119 …return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, asyncCall.…
DAsyncDuplexStreamingCall.cs29 public sealed class AsyncDuplexStreamingCall<TRequest, TResponse> : IDisposable class
47 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall() method in Grpc.Core.AsyncDuplexStreamingCall
DCallInvoker.cs65 …public abstract AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T…
DClientBase.cs192 …public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T… in AsyncDuplexStreamingCall() method in Grpc.Core.ClientBase.ClientBaseConfiguration.ClientBaseConfigurationInterceptor
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DBenchmarkServiceGrpc.cs225 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingCall()
236 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingCall()
238 return CallInvoker.AsyncDuplexStreamingCall(__Method_StreamingCall, null, options); in StreamingCall()
294 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingBothWays()
304 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingBothWays()
306 return CallInvoker.AsyncDuplexStreamingCall(__Method_StreamingBothWays, null, options); in StreamingBothWays()
DWorkerServiceGrpc.cs170 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ServerArgs, global::Grpc.Testin… in RunServer()
184 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ServerArgs, global::Grpc.Testin… in RunServer()
186 return CallInvoker.AsyncDuplexStreamingCall(__Method_RunServer, null, options); in RunServer()
200 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testin… in RunClient()
214 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testin… in RunClient()
216 return CallInvoker.AsyncDuplexStreamingCall(__Method_RunClient, null, options); in RunClient()
DTestGrpc.cs431 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in FullDuplexCall()
442 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in FullDuplexCall()
444 return CallInvoker.AsyncDuplexStreamingCall(__Method_FullDuplexCall, null, options); in FullDuplexCall()
456 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in HalfDuplexCall()
468 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in HalfDuplexCall()
470 return CallInvoker.AsyncDuplexStreamingCall(__Method_HalfDuplexCall, null, options); in HalfDuplexCall()
DClientRunners.cs286 using (var call = Calls.AsyncDuplexStreamingCall(callDetails)) in RunGenericStreamingAsync()
/external/grpc-grpc/src/csharp/Grpc.Reflection/
DReflectionGrpc.cs97 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Reflection.V1Alpha.ServerReflectionRequ… in ServerReflectionInfo()
107 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Reflection.V1Alpha.ServerReflectionRequ… in ServerReflectionInfo()
109 return CallInvoker.AsyncDuplexStreamingCall(__Method_ServerReflectionInfo, null, options); in ServerReflectionInfo()
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DUnimplementedCallInvoker.cs55 …public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T… in AsyncDuplexStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs208 …public virtual grpc::AsyncDuplexStreamingCall<global::Math.DivArgs, global::Math.DivReply> DivMany… in DivMany()
220 …public virtual grpc::AsyncDuplexStreamingCall<global::Math.DivArgs, global::Math.DivReply> DivMany… in DivMany()
222 return CallInvoker.AsyncDuplexStreamingCall(__Method_DivMany, null, options); in DivMany()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/
DRouteGuideGrpc.cs295 …public virtual grpc::AsyncDuplexStreamingCall<global::Routeguide.RouteNote, global::Routeguide.Rou… in RouteChat()
307 …public virtual grpc::AsyncDuplexStreamingCall<global::Routeguide.RouteNote, global::Routeguide.Rou… in RouteChat()
309 return CallInvoker.AsyncDuplexStreamingCall(__Method_RouteChat, null, options); in RouteChat()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DShutdownHookPendingCallTest.cs50 var call = Calls.AsyncDuplexStreamingCall(helper.CreateDuplexStreamingCall()); in ProcessExitHookCanCleanupAbandonedCall()
DShutdownTest.cs58 var call = Calls.AsyncDuplexStreamingCall(helper.CreateDuplexStreamingCall()); in AbandonedCall_ServerKillAsync()
DAppDomainUnloadTest.cs71 var call = Calls.AsyncDuplexStreamingCall(helper.CreateDuplexStreamingCall());
DCompressionTest.cs89 … var call = Calls.AsyncDuplexStreamingCall(helper.CreateDuplexStreamingCall(callOptions)); in WriteOptions_DuplexStreaming()
DResponseHeadersTest.cs128 var call = Calls.AsyncDuplexStreamingCall(helper.CreateDuplexStreamingCall()); in ResponseHeadersAsync_DuplexStreamingCall()
DClientServerTest.cs267 var call = Calls.AsyncDuplexStreamingCall(helper.CreateDuplexStreamingCall()); in DuplexStreamingCall()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DClientInterceptorTest.cs166 …public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T… in AsyncDuplexStreamingCall() method in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.CallbackInterceptor
/external/grpc-grpc/src/csharp/Grpc.Examples.Tests/
DMathClientMockableTest.cs96 …var fakeCall = TestCalls.AsyncDuplexStreamingCall<DivArgs, DivReply>(mockRequestStream.Object, moc… in ClientBaseDuplexStreamingCallCanBeMocked()