Home
last modified time | relevance | path

Searched refs:AsyncServerStreamingCall (Results 1 – 21 of 21) sorted by relevance

/external/grpc-grpc/src/csharp/Grpc.Core/Interceptors/
DInterceptingCallInvoker.cs68 …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()
DInterceptor.cs104 …public delegate AsyncServerStreamingCall<TResponse> AsyncServerStreamingCallContinuation<TRequest,…
232 …public virtual AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(T…
DCallInvokerExtensions.cs127 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.Interceptors.CallInvokerExtensions.MetadataInterceptor
/external/grpc-grpc/src/csharp/Grpc.Core.Testing/
DTestCalls.cs57 public static AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TResponse>( in AsyncServerStreamingCall() method in Grpc.Core.Testing.TestCalls
61 …return new AsyncServerStreamingCall<TResponse>(responseStream, responseHeadersAsync, getStatusFunc… in AsyncServerStreamingCall()
/external/grpc-grpc/src/csharp/Grpc.Core/
DDefaultCallInvoker.cs63 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.DefaultCallInvoker
66 return Calls.AsyncServerStreamingCall(call, request); in AsyncServerStreamingCall()
DCalls.cs74 …public static AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(Ca…
81 …return new AsyncServerStreamingCall<TResponse>(responseStream, asyncCall.ResponseHeadersAsync, asy…
DAsyncServerStreamingCall.cs28 public sealed class AsyncServerStreamingCall<TResponse> : IDisposable class
44 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall() method in Grpc.Core.AsyncServerStreamingCall
DCallInvoker.cs48 …public abstract AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(…
DClientBase.cs182 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.ClientBase.ClientBaseConfiguration.ClientBaseConfigurationInterceptor
/external/grpc-grpc/src/csharp/Grpc.Core/Internal/
DUnimplementedCallInvoker.cs45 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.Internal.UnimplementedCallInvoker
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DMetricsGrpc.cs121 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(glo… in GetAllGauges()
132 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.GaugeResponse> GetAllGauges(glo… in GetAllGauges()
134 return CallInvoker.AsyncServerStreamingCall(__Method_GetAllGauges, null, options, request); in GetAllGauges()
DBenchmarkServiceGrpc.cs271 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.SimpleResponse> StreamingFromSe… in StreamingFromServer()
282 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.SimpleResponse> StreamingFromSe… in StreamingFromServer()
284 … return CallInvoker.AsyncServerStreamingCall(__Method_StreamingFromServer, null, options, request); in StreamingFromServer()
DTestGrpc.cs385 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.StreamingOutputCallResponse> St… in StreamingOutputCall()
396 …public virtual grpc::AsyncServerStreamingCall<global::Grpc.Testing.StreamingOutputCallResponse> St… in StreamingOutputCall()
398 … return CallInvoker.AsyncServerStreamingCall(__Method_StreamingOutputCall, null, options, request); in StreamingOutputCall()
/external/grpc-grpc/src/csharp/Grpc.Examples/
DMathGrpc.cs234 …public virtual grpc::AsyncServerStreamingCall<global::Math.Num> Fib(global::Math.FibArgs request, … in Fib()
246 …public virtual grpc::AsyncServerStreamingCall<global::Math.Num> Fib(global::Math.FibArgs request, … in Fib()
248 return CallInvoker.AsyncServerStreamingCall(__Method_Fib, null, options, request); in Fib()
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/
DRouteGuideGrpc.cs240 …public virtual grpc::AsyncServerStreamingCall<global::Routeguide.Feature> ListFeatures(global::Rou… in ListFeatures()
255 …public virtual grpc::AsyncServerStreamingCall<global::Routeguide.Feature> ListFeatures(global::Rou… in ListFeatures()
257 return CallInvoker.AsyncServerStreamingCall(__Method_ListFeatures, null, options, request); in ListFeatures()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/
DResponseHeadersTest.cs109 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ResponseHeadersAsync_ServerStreamingCall()
187 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in WriteResponseHeaders_NotAllowedAfterWrite()
DClientServerTest.cs197 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), "A B C"); in ServerStreamingCall()
209 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ServerStreamingCall_EndOfStreamIsIdempotent()
224 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ServerStreamingCall_ErrorCanBeAwaitedTwice()
243 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ServerStreamingCall_TrailersFromMultipleSourcesGetConcatenated()
DMarshallingErrorsTest.cs99 … var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), "REQUEST"); in ResponseParsingError_StreamingResponse()
DCallCancellationTest.cs162 var call = Calls.AsyncServerStreamingCall(helper.CreateServerStreamingCall(), ""); in ServerStreamingCall_CancelClientSideRead()
/external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DClientInterceptorTest.cs154 …public override AsyncServerStreamingCall<TResponse> AsyncServerStreamingCall<TRequest, TResponse>(… in AsyncServerStreamingCall() method in Grpc.Core.Interceptors.Tests.ClientInterceptorTest.CallbackInterceptor
/external/grpc-grpc/src/csharp/Grpc.Examples.Tests/
DMathClientMockableTest.cs83 …var fakeCall = TestCalls.AsyncServerStreamingCall<Num>(mockResponseStream.Object, Task.FromResult(… in ClientBaseServerStreamingCallCanBeMocked()