Home
last modified time | relevance | path

Searched defs:requestStream (Results 1 – 21 of 21) sorted by relevance

/third_party/grpc/src/csharp/Grpc.Core.Api/
DAsyncDuplexStreamingCall.cs31 readonly IClientStreamWriter<TRequest> requestStream; field in Grpc.Core.AsyncDuplexStreamingCall
44 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall()
66 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall()
DAsyncClientStreamingCall.cs32 readonly IClientStreamWriter<TRequest> requestStream; field in Grpc.Core.AsyncClientStreamingCall
45 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall()
67 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall()
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DTestServiceImpl.cs61 …StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> reque… in StreamingInputCall()
74 …public override async Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestSt… in FullDuplexCall()
89 …public override Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, … in HalfDuplexCall()
DWorkerServiceImpl.cs42 …public override async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWr… in RunServer()
66 …public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWr… in RunClient()
DBenchmarkServiceImpl.cs44 …public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerS… in StreamingCall()
DBenchmarkServiceGrpc.cs131 …tem.Threading.Tasks.Task StreamingCall(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest… in StreamingCall()
143 …ng.SimpleResponse> StreamingFromClient(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest… in StreamingFromClient()
169 …Threading.Tasks.Task StreamingBothWays(grpc::IAsyncStreamReader<global::Grpc.Testing.SimpleRequest… in StreamingBothWays()
DServerRunners.cs104 …public async Task StreamingCall(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byte… in StreamingCall()
DWorkerServiceGrpc.cs120 …l::System.Threading.Tasks.Task RunServer(grpc::IAsyncStreamReader<global::Grpc.Testing.ServerArgs>… in RunServer()
137 …l::System.Threading.Tasks.Task RunClient(grpc::IAsyncStreamReader<global::Grpc.Testing.ClientArgs>… in RunClient()
DSslCredentialsTest.cs270 …StreamingInputCallResponse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> reque… in StreamingInputCall()
DTestGrpc.cs196 …CallResponse> StreamingInputCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingInputCallR… in StreamingInputCall()
210 …eading.Tasks.Task FullDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCall… in FullDuplexCall()
225 …eading.Tasks.Task HalfDuplexCall(grpc::IAsyncStreamReader<global::Grpc.Testing.StreamingOutputCall… in HalfDuplexCall()
/third_party/flatbuffers/tests/
Dmonster_test_grpc.d.ts16 requestStream: boolean; // false property
26 requestStream: boolean; // false property
36 requestStream: boolean; // true property
46 requestStream: boolean; // true property
/third_party/grpc/src/csharp/Grpc.Examples/
DMathServiceImpl.cs50 …public override async Task<Num> Sum(IAsyncStreamReader<Num> requestStream, ServerCallContext conte… in Sum()
61 …public override async Task DivMany(IAsyncStreamReader<DivArgs> requestStream, IServerStreamWriter<… in DivMany()
DMathGrpc.cs125 …l global::System.Threading.Tasks.Task DivMany(grpc::IAsyncStreamReader<global::Math.DivArgs> reque… in DivMany()
151 …stem.Threading.Tasks.Task<global::Math.Num> Sum(grpc::IAsyncStreamReader<global::Math.Num> request… in Sum()
/third_party/grpc/src/csharp/Grpc.Core/
DCalls.cs105 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
127 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
/third_party/grpc/examples/csharp/RouteGuide/RouteGuideServer/
DRouteGuideImpl.cs67 …public override async Task<RouteSummary> RecordRoute(IAsyncStreamReader<Point> requestStream, Serv… in RecordRoute()
106 …public override async Task RouteChat(IAsyncStreamReader<RouteNote> requestStream, IServerStreamWri… in RouteChat()
/third_party/grpc/src/csharp/Grpc.Core.Testing/
DTestCalls.cs46 IClientStreamWriter<TRequest> requestStream, Task<TResponse> responseAsync, in AsyncClientStreamingCall()
69 … IClientStreamWriter<TRequest> requestStream, IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall()
/third_party/flatbuffers/grpc/examples/ts/greeter/src/
Dgreeter_grpc.d.ts14 requestStream: boolean; // false property
24 requestStream: boolean; // false property
/third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/
DServerInterceptorTest.cs154 …nse> ClientStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream,… in ClientStreamingServerHandler()
166 …Task DuplexStreamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream,… in DuplexStreamingServerHandler()
/third_party/grpc/src/csharp/Grpc.Reflection/
DReflectionServiceImpl.cs66 …public override async Task ServerReflectionInfo(IAsyncStreamReader<ServerReflectionRequest> reques… in ServerReflectionInfo()
DReflectionGrpc.cs90 …ks.Task ServerReflectionInfo(grpc::IAsyncStreamReader<global::Grpc.Reflection.V1Alpha.ServerReflec… in ServerReflectionInfo()
/third_party/grpc/src/csharp/Grpc.Core/Internal/
DServerCallHandler.cs282 …private Task UnimplementedMethod(IAsyncStreamReader<byte[]> requestStream, IServerStreamWriter<byt… in UnimplementedMethod()