Home
last modified time | relevance | path

Searched refs:ServerCalls (Results 1 – 25 of 29) sorted by relevance

12

/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java92 ServerCalls.asyncBidiStreamingCall( in runtimeStreamObserverIsServerCallStreamObserver()
93 new ServerCalls.BidiStreamingMethod<Integer, Integer>() { in runtimeStreamObserverIsServerCallStreamObserver()
113 return new ServerCalls.NoopStreamObserver<Integer>(); in runtimeStreamObserverIsServerCallStreamObserver()
142 ServerCalls.asyncBidiStreamingCall( in cannotSetOnCancelHandlerAfterServiceInvocation()
143 new ServerCalls.BidiStreamingMethod<Integer, Integer>() { in cannotSetOnCancelHandlerAfterServiceInvocation()
147 return new ServerCalls.NoopStreamObserver<Integer>(); in cannotSetOnCancelHandlerAfterServiceInvocation()
170 ServerCalls.asyncBidiStreamingCall( in cannotSetOnReadyHandlerAfterServiceInvocation()
171 new ServerCalls.BidiStreamingMethod<Integer, Integer>() { in cannotSetOnReadyHandlerAfterServiceInvocation()
175 return new ServerCalls.NoopStreamObserver<Integer>(); in cannotSetOnReadyHandlerAfterServiceInvocation()
198 ServerCalls.asyncBidiStreamingCall( in cannotDisableAutoFlowControlAfterServiceInvocation()
[all …]
DClientCallsTest.java41 import io.grpc.stub.ServerCalls.NoopStreamObserver;
376 .addMethod(STREAMING_METHOD, ServerCalls.asyncBidiStreamingCall( in inprocessTransportInboundFlowControl()
377 new ServerCalls.BidiStreamingMethod<Integer, Integer>() { in inprocessTransportInboundFlowControl()
394 return new ServerCalls.NoopStreamObserver<Integer>() { in inprocessTransportInboundFlowControl()
457 .addMethod(STREAMING_METHOD, ServerCalls.asyncBidiStreamingCall( in inprocessTransportOutboundFlowControl()
458 new ServerCalls.BidiStreamingMethod<Integer, Integer>() { in inprocessTransportOutboundFlowControl()
/external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/
DHandshakerServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
193 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
194 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
195 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
196 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/reflection/v1alpha/
DServerReflectionGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
185 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
186 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
187 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
188 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/grpclb/src/generated/main/grpc/io/grpc/lb/v1/
DLoadBalancerGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
183 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
184 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
185 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
186 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/services/src/generated/test/grpc/io/grpc/reflection/testing/
DAnotherDynamicServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
219 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
220 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
221 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
222 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
DDynamicServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
219 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
220 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
221 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
222 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
DReflectableServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
192 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
193 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
194 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
195 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/health/v1/
DHealthGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
192 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
193 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
194 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
195 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DReportQpsScenarioServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
204 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
205 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
206 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
207 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
DWorkerServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
428 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
429 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
430 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
431 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
DBenchmarkServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
474 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
475 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
476 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
477 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DUnimplementedServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
224 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
225 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
226 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
227 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
DMetricsServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
279 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
280 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
281 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
282 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
DReconnectServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
277 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
278 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
279 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
280 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
DTestServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
752 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
753 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
754 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
755 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc/src/csharp/Grpc.Core/
DServerServiceDefinition.cs88 callHandlers.Add(method.FullName, ServerCalls.UnaryCall(method, handler)); in callHandlers.Add()
106 callHandlers.Add(method.FullName, ServerCalls.ClientStreamingCall(method, handler)); in callHandlers.Add()
124 callHandlers.Add(method.FullName, ServerCalls.ServerStreamingCall(method, handler)); in callHandlers.Add()
142 callHandlers.Add(method.FullName, ServerCalls.DuplexStreamingCall(method, handler)); in callHandlers.Add()
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestDeprecatedService.java.txt11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
227 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
228 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
229 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
230 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
DTestService.java.txt11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
550 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
551 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
552 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
553 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestDeprecatedService.java.txt11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
253 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
254 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
255 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
256 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/compiler/src/test/golden/
DTestDeprecatedService.java.txt11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
228 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
229 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
230 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
231 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorageGrpc.java18 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
19 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
20 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
21 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
22 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
23 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
404 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
405 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
406 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
407 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
413 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
414 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
415 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
416 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/
DChannelzGrpc.java11 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
12 import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
13 import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
14 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
15 import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
16 import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
638 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
639 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
640 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
641 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/advanced/
DHelloJsonServer.java19 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
29 import io.grpc.stub.ServerCalls.UnaryMethod;

12