| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/ |
| D | ManualFlowControlClient.java | 50 ClientCallStreamObserver<HelloRequest> requestStream; in main()
53 public void beforeStart(final ClientCallStreamObserver<HelloRequest> requestStream) { in main()
54 this.requestStream = requestStream; in main()
57 requestStream.disableAutoInboundFlowControl(); in main()
70 requestStream.setOnReadyHandler(new Runnable() { in main()
77 while (requestStream.isReady()) { in main()
83 requestStream.onNext(request); in main()
86 requestStream.onCompleted(); in main()
97 requestStream.request(1); in main()
|
| /external/grpc-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()
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Internal/ |
| D | AsyncCallTest.cs | 181 var requestStream = new ClientRequestStream<string, string>(asyncCall); in ClientStreaming_MoreRequests_Success()
183 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_MoreRequests_Success()
187 var writeTask2 = requestStream.WriteAsync("request2"); in ClientStreaming_MoreRequests_Success()
191 var completeTask = requestStream.CompleteAsync(); in ClientStreaming_MoreRequests_Success()
207 var requestStream = new ClientRequestStream<string, string>(asyncCall); in ClientStreaming_WriteFailureThrowsRpcException()
209 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException()
230 var requestStream = new ClientRequestStream<string, string>(asyncCall); in ClientStreaming_WriteFailureThrowsRpcException2()
232 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException2()
251 var requestStream = new ClientRequestStream<string, string>(asyncCall); in ClientStreaming_WriteFailureThrowsRpcException3()
253 var writeTask = requestStream.WriteAsync("request1"); in ClientStreaming_WriteFailureThrowsRpcException3()
[all …]
|
| D | AsyncCallServerTest.cs | 75 var requestStream = new ServerRequestStream<string, string>(asyncCallServer); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()
77 var moveNextTask = requestStream.MoveNext(); in CancelNotificationAfterStartDisposesAfterPendingReadFinishes()
90 var requestStream = new ServerRequestStream<string, string>(asyncCallServer); in ReadAfterCancelNotificationCanSucceed()
95 var moveNextTask = requestStream.MoveNext(); in ReadAfterCancelNotificationCanSucceed()
105 var requestStream = new ServerRequestStream<string, string>(asyncCallServer); in ReadCompletionFailureClosesRequestStream()
109 var moveNextTask = requestStream.MoveNext(); in ReadCompletionFailureClosesRequestStream()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | AsyncDuplexStreamingCall.cs | 31 readonly IClientStreamWriter<TRequest> requestStream; field in Grpc.Core.AsyncDuplexStreamingCall
47 public AsyncDuplexStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncDuplexStreamingCall() argument
54 this.requestStream = requestStream; in AsyncDuplexStreamingCall()
80 return requestStream;
|
| D | AsyncClientStreamingCall.cs | 32 readonly IClientStreamWriter<TRequest> requestStream; field in Grpc.Core.AsyncClientStreamingCall
48 public AsyncClientStreamingCall(IClientStreamWriter<TRequest> requestStream, in AsyncClientStreamingCall() argument
55 this.requestStream = requestStream; in AsyncClientStreamingCall()
92 return requestStream;
|
| D | Calls.cs | 98 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
99 …return new AsyncClientStreamingCall<TRequest, TResponse>(requestStream, resultTask, asyncCall.Resp…
117 var requestStream = new ClientRequestStream<TRequest, TResponse>(asyncCall); field in Grpc.Core.Calls.TResponse
119 …return new AsyncDuplexStreamingCall<TRequest, TResponse>(requestStream, responseStream, asyncCall.…
|
| D | ServerMethods.cs | 37 …reamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, ServerCallCon…
55 …reamingServerMethod<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStream…
|
| /external/nanohttpd/core/src/test/java/fi/iki/elonen/ |
| D | HttpKeepAliveTest.java | 93 PipedOutputStream requestStream = new PipedOutputStream(); in testManyRequests()
94 PipedInputStream inputStream = new PipedInputStream(requestStream); in testManyRequests()
100 requestStream.write(request.getBytes()); in testManyRequests()
101 requestStream.flush(); in testManyRequests()
110 requestStream.write(closeReq.getBytes()); in testManyRequests()
112 requestStream.flush(); in testManyRequests()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | ServerCallHandler.cs | 61 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
69 … GrpcPreconditions.CheckArgument(await requestStream.MoveNext().ConfigureAwait(false)); in HandleCall()
70 var request = requestStream.Current; in HandleCall()
125 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
132 … GrpcPreconditions.CheckArgument(await requestStream.MoveNext().ConfigureAwait(false)); in HandleCall()
133 var request = requestStream.Current; in HandleCall()
188 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
196 var response = await handler(requestStream, context).ConfigureAwait(false); in HandleCall()
223 …ndler<TRequest, TResponse>(method, (requestStream, context) => interceptor.ClientStreamingServerHa… in Intercept()
251 var requestStream = new ServerRequestStream<TRequest, TResponse>(asyncCall); in HandleCall()
[all …]
|
| /external/grpc-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()
|
| /external/grpc-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()
|
| /external/grpc-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()
|
| /external/grpc-grpc/src/csharp/Grpc.Examples/ |
| D | MathServiceImpl.cs | 52 …public override async Task<Num> Sum(IAsyncStreamReader<Num> requestStream, ServerCallContext conte… in Sum() argument
55 await requestStream.ForEachAsync(num => in Sum()
63 …public override async Task DivMany(IAsyncStreamReader<DivArgs> requestStream, IServerStreamWriter<… in DivMany() argument
65 …await requestStream.ForEachAsync(async divArgs => await responseStream.WriteAsync(DivInternal(divA… in DivMany()
|
| /external/grpc-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,
|
| /external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
| D | ClientCallsTest.java | 261 public void beforeStart(ClientCallStreamObserver<Integer> requestStream) { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
262 requestStream.disableAutoInboundFlowControl(); in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages()
290 public void beforeStart(ClientCallStreamObserver<Integer> requestStream) { in callStreamObserverPropagatesFlowControlRequestsToCall()
291 requestStream.disableAutoInboundFlowControl(); in callStreamObserverPropagatesFlowControlRequestsToCall()
335 public void beforeStart(ClientCallStreamObserver<Integer> requestStream) { in canCaptureInboundFlowControlForServerStreamingObserver()
336 requestStream.disableAutoInboundFlowControl(); in canCaptureInboundFlowControlForServerStreamingObserver()
337 requestStream.request(5); in canCaptureInboundFlowControlForServerStreamingObserver()
415 public void beforeStart(final ClientCallStreamObserver<Integer> requestStream) { in inprocessTransportInboundFlowControl()
416 requestStream.disableAutoInboundFlowControl(); in inprocessTransportInboundFlowControl()
495 public void beforeStart(final ClientCallStreamObserver<Integer> requestStream) { in inprocessTransportOutboundFlowControl()
[all …]
|
| /external/grpc-grpc/src/csharp/Grpc.Core/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);
|
| /external/grpc-grpc/src/csharp/Grpc.Core.Tests/Interceptors/ |
| D | ServerInterceptorTest.cs | 107 …eamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, ServerCallCon… in ClientStreamingServerHandler() argument
110 return continuation(requestStream, context); in ClientStreamingServerHandler()
119 …eamingServerHandler<TRequest, TResponse>(IAsyncStreamReader<TRequest> requestStream, IServerStream… in DuplexStreamingServerHandler() argument
122 return continuation(requestStream, responseStream, context); in DuplexStreamingServerHandler()
|
| /external/grpc-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()
|