Home
last modified time | relevance | path

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

12

/third_party/grpc/src/csharp/Grpc.Core.Api/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
/third_party/grpc/src/csharp/Grpc.Core.Api/
DAsyncDuplexStreamingCall.cs29 public sealed class AsyncDuplexStreamingCall<TRequest, TResponse> : IDisposable class
44 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall() method in Grpc.Core.AsyncDuplexStreamingCall
66 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall() method in Grpc.Core.AsyncDuplexStreamingCall
DCallInvoker.cs63 …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
/third_party/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()
/third_party/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.cs121 …public static AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, TRe…
129 return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream,
DForwardedTypes.cs30 [assembly:TypeForwardedToAttribute(typeof(AsyncDuplexStreamingCall<,>))]
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DBenchmarkServiceGrpc.cs256 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingCall()
267 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingCall()
269 return CallInvoker.AsyncDuplexStreamingCall(__Method_StreamingCall, null, options); in StreamingCall()
325 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingBothWays()
335 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.SimpleRequest, global::Grpc.Tes… in StreamingBothWays()
337 return CallInvoker.AsyncDuplexStreamingCall(__Method_StreamingBothWays, null, options); in StreamingBothWays()
DWorkerServiceGrpc.cs201 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ServerArgs, global::Grpc.Testin… in RunServer()
215 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ServerArgs, global::Grpc.Testin… in RunServer()
217 return CallInvoker.AsyncDuplexStreamingCall(__Method_RunServer, null, options); in RunServer()
231 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testin… in RunClient()
245 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.ClientArgs, global::Grpc.Testin… in RunClient()
247 return CallInvoker.AsyncDuplexStreamingCall(__Method_RunClient, null, options); in RunClient()
DTestGrpc.cs462 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in FullDuplexCall()
473 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in FullDuplexCall()
475 return CallInvoker.AsyncDuplexStreamingCall(__Method_FullDuplexCall, null, options); in FullDuplexCall()
487 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in HalfDuplexCall()
499 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Testing.StreamingOutputCallRequest, glo… in HalfDuplexCall()
501 return CallInvoker.AsyncDuplexStreamingCall(__Method_HalfDuplexCall, null, options); in HalfDuplexCall()
DClientRunners.cs286 using (var call = Calls.AsyncDuplexStreamingCall(callDetails)) in RunGenericStreamingAsync()
/third_party/grpc/src/csharp/Grpc.Core/Internal/
DUnimplementedCallInvoker.cs55 …public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T… in AsyncDuplexStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/third_party/grpc/src/csharp/Grpc.Core.Api/Internal/
DUnimplementedCallInvoker.cs55 …public override AsyncDuplexStreamingCall<TRequest, TResponse> AsyncDuplexStreamingCall<TRequest, T… in AsyncDuplexStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/third_party/grpc/src/csharp/Grpc.Reflection/
DReflectionGrpc.cs128 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Reflection.V1Alpha.ServerReflectionRequ… in ServerReflectionInfo()
138 …public virtual grpc::AsyncDuplexStreamingCall<global::Grpc.Reflection.V1Alpha.ServerReflectionRequ… in ServerReflectionInfo()
140 return CallInvoker.AsyncDuplexStreamingCall(__Method_ServerReflectionInfo, null, options); in ServerReflectionInfo()
/third_party/grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs239 …public virtual grpc::AsyncDuplexStreamingCall<global::Math.DivArgs, global::Math.DivReply> DivMany… in DivMany()
251 …public virtual grpc::AsyncDuplexStreamingCall<global::Math.DivArgs, global::Math.DivReply> DivMany… in DivMany()
253 return CallInvoker.AsyncDuplexStreamingCall(__Method_DivMany, null, options); in DivMany()
/third_party/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()
/third_party/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
/third_party/grpc/src/csharp/Grpc.Examples.Tests/
DMathClientMockableTest.cs96 …var fakeCall = TestCalls.AsyncDuplexStreamingCall<DivArgs, DivReply>(mockRequestStream.Object, moc… in ClientBaseDuplexStreamingCallCanBeMocked()

12