| /third_party/grpc/src/csharp/Grpc.IntegrationTesting/ |
| D | WorkerServiceImpl.cs | 42 …public override async Task RunServer(IAsyncStreamReader<ServerArgs> requestStream, IServerStreamWr… in RunServer() argument
44 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunServer()
45 var serverConfig = requestStream.Current.Setup; in RunServer()
55 while (await requestStream.MoveNext()) in RunServer()
57 var reset = requestStream.Current.Mark.Reset; in RunServer()
66 …public override async Task RunClient(IAsyncStreamReader<ClientArgs> requestStream, IServerStreamWr… in RunClient() argument
68 GrpcPreconditions.CheckState(await requestStream.MoveNext()); in RunClient()
69 var clientConfig = requestStream.Current.Setup; in RunClient()
77 while (await requestStream.MoveNext()) in RunClient()
79 var reset = requestStream.Current.Mark.Reset; in RunClient()
|
| D | TestServiceImpl.cs | 61 …nse> StreamingInputCall(IAsyncStreamReader<StreamingInputCallRequest> requestStream, ServerCallCon… in StreamingInputCall() argument
66 await requestStream.ForEachAsync(request => in StreamingInputCall()
74 …nc Task FullDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStream… in FullDuplexCall() argument
78 await requestStream.ForEachAsync(async request => in FullDuplexCall()
89 …de Task HalfDuplexCall(IAsyncStreamReader<StreamingOutputCallRequest> requestStream, IServerStream… in HalfDuplexCall() argument
|
| D | BenchmarkServiceImpl.cs | 44 …public override async Task StreamingCall(IAsyncStreamReader<SimpleRequest> requestStream, IServerS… in StreamingCall() argument
46 await requestStream.ForEachAsync(async request => in StreamingCall()
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/ |
| D | AsyncDuplexStreamingCall.cs | 31 readonly IClientStreamWriter<TRequest> requestStream; field in Grpc.Core.AsyncDuplexStreamingCall
44 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall() argument
51 this.requestStream = requestStream; in AsyncDuplexStreamingCall()
66 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall() argument
74 this.requestStream = requestStream; in AsyncDuplexStreamingCall()
97 return requestStream;
|
| D | AsyncClientStreamingCall.cs | 32 readonly IClientStreamWriter<TRequest> requestStream; field in Grpc.Core.AsyncClientStreamingCall
45 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall() argument
52 this.requestStream = requestStream; in AsyncClientStreamingCall()
67 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall() argument
75 this.requestStream = requestStream; in AsyncClientStreamingCall()
109 return requestStream;
|
| D | ServerMethods.cs | 37 …reamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, ServerCallCon…
55 …reamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStream…
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallTest.cs | 185 var requestStream = new ClientRequestStream<string, string>(asyncCall); in ClientStreaming_MoreRequests_Success()
187 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_MoreRequests_Success()
191 var writeTask2 = requestStream.WriteAsync("request2"); in ClientStreaming_MoreRequests_Success()
195 var completeTask = requestStream.CompleteAsync(); in ClientStreaming_MoreRequests_Success()
211 var requestStream = new ClientRequestStream<string, string>(asyncCall); in ClientStreaming_WriteFailureThrowsRpcException()
213 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException()
234 var requestStream = new ClientRequestStream<string, string>(asyncCall); in ClientStreaming_WriteFailureThrowsRpcException2()
236 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException2()
255 var requestStream = new ClientRequestStream<string, string>(asyncCall); in ClientStreaming_WriteFailureThrowsRpcException3()
257 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException3()
[all …]
|
| D | AsyncCallServerTest.cs | 78 var requestStream = new ServerRequestStream<string, string>(asyncCallServer); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()
80 var moveNextTask = requestStream.MoveNext(); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()
93 var requestStream = new ServerRequestStream<string, string>(asyncCallServer); in ReadAfterCancelNotificationCanSucceed()
98 var moveNextTask = requestStream.MoveNext(); in ReadAfterCancelNotificationCanSucceed()
108 var requestStream = new ServerRequestStream<string, string>(asyncCallServer); in ReadCompletionFailureClosesRequestStream()
112 var moveNextTask = requestStream.MoveNext(); in ReadCompletionFailureClosesRequestStream()
|
| /third_party/grpc/examples/csharp/RouteGuide/RouteGuideServer/ |
| D | RouteGuideImpl.cs | 67 …erride async Task<RouteSummary> RecordRoute(IAsyncStreamReader<Point> requestStream, ServerCallCon… in RecordRoute() argument
76 while (await requestStream.MoveNext()) in RecordRoute()
78 var point = requestStream.Current; in RecordRoute()
106 …public override async Task RouteChat(IAsyncStreamReader<RouteNote> requestStream, IServerStreamWri… in RouteChat() argument
108 while (await requestStream.MoveNext()) in RouteChat()
110 var note = requestStream.Current; in RouteChat()
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 60 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
68 … GrpcPreconditions.CheckArgument(await requestStream.MoveNext().ConfigureAwait(false)); in HandleCall()
69 var request = requestStream.Current; in HandleCall()
119 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
126 … GrpcPreconditions.CheckArgument(await requestStream.MoveNext().ConfigureAwait(false)); in HandleCall()
127 var request = requestStream.Current; in HandleCall()
177 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
185 var response = await handler(requestStream, context).ConfigureAwait(false); in HandleCall()
235 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
242 await handler(requestStream, responseStream, context).ConfigureAwait(false); in HandleCall()
[all …]
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/ |
| D | MockServiceHelper.cs | 91 ….AddMethod(clientStreamingMethod, (requestStream, context) => clientStreamingHandler(requestStream… in MockServiceHelper()
93 ….AddMethod(duplexStreamingMethod, (requestStream, responseStream, context) => duplexStreamingHandl… in MockServiceHelper()
104 …clientStreamingHandler = new ClientStreamingServerMethod<string, string>((requestStream, context) … in MockServiceHelper()
116 …duplexStreamingHandler = new DuplexStreamingServerMethod<string, string>((requestStream, responseS… in MockServiceHelper()
|
| D | CallCancellationTest.cs | 62 …treamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStream, context) => in ClientStreamingCall_CancelAfterBegin()
65 await requestStream.ToListAsync(); in ClientStreamingCall_CancelAfterBegin()
94 …treamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStream, context) => in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
102 var moveNextResult = await requestStream.MoveNext(); in ClientStreamingCall_ServerSideReadAfterCancelNotificationReturnsNull()
128 …treamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStream, context) => in ClientStreamingCall_CancelServerSideRead()
131 var moveNextTask = requestStream.MoveNext(cts.Token); in ClientStreamingCall_CancelServerSideRead()
|
| D | MarshallingErrorsTest.cs | 120 …treamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStream, context) => in RequestParsingError_StreamingRequest()
125 await requestStream.MoveNext(); in RequestParsingError_StreamingRequest()
155 …treamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStream, context) => in RequestSerializationError_ClientStreaming()
157 CollectionAssert.AreEqual(new[] { "A", "B" }, await requestStream.ToListAsync()); in RequestSerializationError_ClientStreaming()
|
| D | ResponseHeadersTest.cs | 86 …treamingHandler = new ClientStreamingServerMethod<string, string>(async (requestStream, context) => in ResponseHeadersAsync_ClientStreamingCall()
119 …amingHandler = new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStrea… in ResponseHeadersAsync_DuplexStreamingCall()
122 while (await requestStream.MoveNext()) in ResponseHeadersAsync_DuplexStreamingCall()
124 await responseStream.WriteAsync(requestStream.Current); in ResponseHeadersAsync_DuplexStreamingCall()
|
| D | ShutdownHookPendingCallTest.cs | 44 …amingHandler = new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStrea… in ProcessExitHookCanCleanupAbandonedCall()
47 await requestStream.ToListAsync(); in ProcessExitHookCanCleanupAbandonedCall()
|
| D | ShutdownTest.cs | 52 …amingHandler = new DuplexStreamingServerMethod<string, string>(async (requestStream, responseStrea… in AbandonedCall_ServerKillAsync()
55 await requestStream.ToListAsync(); in AbandonedCall_ServerKillAsync()
|
| /third_party/flatbuffers/tests/ |
| D | monster_test_grpc.js | 37 requestStream: false,
48 requestStream: false,
59 requestStream: true,
70 requestStream: true,
|
| /third_party/grpc/src/csharp/Grpc.Core.Testing/ |
| D | TestCalls.cs | 46 IClientStreamWriter<TRequest> requestStream, Task<TResponse> responseAsync, in AsyncClientStreamingCall() argument
50 …return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, responseAsync, responseHea… in AsyncClientStreamingCall()
69 … IClientStreamWriter<TRequest> requestStream, IAsyncStreamReader<TResponse> responseStream, in AsyncDuplexStreamingCall() argument
73 …return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, responseHe… in AsyncDuplexStreamingCall()
|
| /third_party/grpc/src/csharp/Grpc.Examples/ |
| D | MathServiceImpl.cs | 50 …public override async Task<Num> Sum(IAsyncStreamReader<Num> requestStream, ServerCallContext conte… in Sum() argument
53 await requestStream.ForEachAsync(num => in Sum()
61 …public override async Task DivMany(IAsyncStreamReader<DivArgs> requestStream, IServerStreamWriter<… in DivMany() argument
63 …await requestStream.ForEachAsync(async divArgs => await responseStream.WriteAsync(DivInternal(divA… in DivMany()
|
| /third_party/grpc/examples/node/static_codegen/route_guide/ |
| D | route_guide_grpc_pb.js | 88 requestStream: false,
105 requestStream: false,
120 requestStream: true,
135 requestStream: true,
|
| /third_party/grpc/src/csharp/Grpc.Core/Interceptors/ |
| D | ServerServiceDefinitionExtensions.cs | 111 …builder.AddMethod(method, (requestStream, context) => interceptor.ClientStreamingServerHandler(req… in AddMethod()
125 …builder.AddMethod(method, (requestStream, responseStream, context) => interceptor.DuplexStreamingS… in AddMethod()
|
| /third_party/grpc/src/csharp/Grpc.Core/ |
| D | Calls.cs | 105 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
106 return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, resultTask,
127 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
129 return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream,
|
| /third_party/grpc/src/csharp/Grpc.Core.Api/Interceptors/ |
| D | Interceptor.cs | 346 …eamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, ServerCallCon…
350 return continuation(requestStream, context);
398 …eamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStream…
402 return continuation(requestStream, responseStream, context);
|
| /third_party/grpc/src/csharp/Grpc.Reflection/ |
| D | ReflectionServiceImpl.cs | 66 …Task ServerReflectionInfo(IAsyncStreamReader<ServerReflectionRequest> requestStream, IServerStream… in ServerReflectionInfo() argument
68 while (await requestStream.MoveNext()) in ServerReflectionInfo()
70 var response = ProcessRequest(requestStream.Current); in ServerReflectionInfo()
|
| /third_party/grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ServerInterceptorTest.cs | 154 …eamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, ServerCallCon… in ClientStreamingServerHandler() argument
157 return continuation(requestStream, context); in ClientStreamingServerHandler()
166 …eamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStream… in DuplexStreamingServerHandler() argument
169 return continuation(requestStream, responseStream, context); in DuplexStreamingServerHandler()
|