Home
last modified time | relevance | path

Searched defs:responseStream (Results 1 – 23 of 23) sorted by relevance

/third_party/grpc/src/csharp/Grpc.Core.Api/
DAsyncServerStreamingCall.cs30 readonly IAsyncStreamReader<TResponse> responseStream; field in Grpc.Core.AsyncServerStreamingCall
41 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall()
60 public AsyncServerStreamingCall(IAsyncStreamReader<TResponse> responseStream, in AsyncServerStreamingCall()
DAsyncDuplexStreamingCall.cs32 readonly IAsyncStreamReader<TResponse> responseStream; field in Grpc.Core.AsyncDuplexStreamingCall
45 IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
67 IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DTestServiceImpl.cs49 …tputCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> resp… in StreamingOutputCall()
74 …r<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> resp… in FullDuplexCall()
89 …r<StreamingOutputCallRequest> requestStream, IServerStreamWriter<StreamingOutputCallResponse> resp… in HalfDuplexCall()
DWorkerServiceImpl.cs42 …erver(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWriter<ServerStatus> responseStre… in RunServer()
66 …lient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWriter<ClientStatus> responseStre… in RunClient()
DBenchmarkServiceImpl.cs44 …l(IAsyncStreamReader<SimpleRequest> requestStream, IServerStreamWriter<SimpleResponse> responseStr… in StreamingCall()
DBenchmarkServiceGrpc.cs131 …Testing.SimpleRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.SimpleRespons… in StreamingCall()
156 …::Grpc.Testing.SimpleRequest request, grpc::IServerStreamWriter<global::Grpc.Testing.SimpleRespons… in StreamingFromServer()
169 …Testing.SimpleRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.SimpleRespons… in StreamingBothWays()
DServerRunners.cs104 …treamingCall(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byte[]> responseStream,… in StreamingCall()
DMetadataCredentialsTest.cs259 …tputCall(StreamingOutputCallRequest request, IServerStreamWriter<StreamingOutputCallResponse> resp… in StreamingOutputCall()
DWorkerServiceGrpc.cs120 …rpc.Testing.ServerArgs> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.ServerStatus… in RunServer()
137 …rpc.Testing.ClientArgs> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.ClientStatus… in RunClient()
DStressTestClient.cs268 …rride async Task GetAllGauges(EmptyMessage request, IServerStreamWriter<GaugeResponse> responseStr… in GetAllGauges()
DMetricsGrpc.cs102 …l::Grpc.Testing.EmptyMessage request, grpc::IServerStreamWriter<global::Grpc.Testing.GaugeResponse… in GetAllGauges()
DTestGrpc.cs184 …mingOutputCallRequest request, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallR… in StreamingOutputCall()
210 …putCallRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallR… in FullDuplexCall()
225 …putCallRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Testing.StreamingOutputCallR… in HalfDuplexCall()
/third_party/grpc/src/csharp/Grpc.Examples/
DMathServiceImpl.cs36 …public override async Task Fib(FibArgs request, IServerStreamWriter<Num> responseStream, ServerCal… in Fib()
61 …sk DivMany(IAsyncStreamReader<DivArgs> requestStream, IServerStreamWriter<DivReply> responseStream… in DivMany()
DMathGrpc.cs125 …mReader<global::Math.DivArgs> requestStream, grpc::IServerStreamWriter<global::Math.DivReply> resp… in DivMany()
139 …g.Tasks.Task Fib(global::Math.FibArgs request, grpc::IServerStreamWriter<global::Math.Num> respons… in Fib()
/third_party/grpc/src/csharp/Grpc.Core/
DCalls.cs84 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
128 var responseStream = new ClientResponseStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
/third_party/grpc/examples/csharp/RouteGuide/RouteGuideServer/
DRouteGuideImpl.cs54 …ic override async Task ListFeatures(Rectangle request, IServerStreamWriter<Feature> responseStream… in ListFeatures()
106 …outeChat(IAsyncStreamReader<RouteNote> requestStream, IServerStreamWriter<RouteNote> responseStrea… in RouteChat()
/third_party/grpc/src/csharp/Grpc.Core.Testing/
DTestCalls.cs58 IAsyncStreamReader<TResponse> responseStream, Task<Metadata> responseHeadersAsync, in AsyncServerStreamingCall()
69 … IClientStreamWriter<TRequest> requestStream, IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
/third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DServerInterceptorTest.cs160 …gServerHandler<TRequest, TResponse>(TRequest request, IServerStreamWriter<TResponse> responseStrea… in ServerStreamingServerHandler()
166 …Response>(IAsyncStreamReader<TRequest> requestStream, IServerStreamWriter<TResponse> responseStrea… in DuplexStreamingServerHandler()
/third_party/grpc/src/csharp/Grpc.HealthCheck/
DHealthServiceImpl.cs156 …ide async Task Watch(HealthCheckRequest request, IServerStreamWriter<HealthCheckResponse> response… in Watch()
DHealthGrpc.cs123 …th.V1.HealthCheckRequest request, grpc::IServerStreamWriter<global::Grpc.Health.V1.HealthCheckResp… in Watch()
/third_party/grpc/src/csharp/Grpc.Reflection/
DReflectionServiceImpl.cs66 …eader<ServerReflectionRequest> requestStream, IServerStreamWriter<ServerReflectionResponse> respon… in ServerReflectionInfo()
DReflectionGrpc.cs90 …ionRequest> requestStream, grpc::IServerStreamWriter<global::Grpc.Reflection.V1Alpha.ServerReflect… in ServerReflectionInfo()
/third_party/grpc/src/csharp/Grpc.Core/Internal/
DServerCallHandler.cs282 …mentedMethod(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byte[]> responseStream,… in UnimplementedMethod()