Home
last modified time | relevance | path

Searched refs:SERVER_STREAMING (Results 1 – 25 of 26) sorted by relevance

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DMethodDescriptorTest.java58 .setType(MethodType.SERVER_STREAMING) in idempotent()
71 assertEquals(MethodType.SERVER_STREAMING, newDescriptor.getType()); in idempotent()
96 .setType(MethodType.SERVER_STREAMING) in safeAndNonUnary()
109 .setType(MethodType.SERVER_STREAMING) in sampledToLocalTracing()
124 .setType(MethodType.SERVER_STREAMING) in sampledToLocalTracing()
/external/grpc-grpc/test/cpp/interop/
Dstress_interop_client.h44 SERVER_STREAMING, enumerator
64 {SERVER_STREAMING, "server_streaming"},
Dstress_interop_client.cc140 case SERVER_STREAMING: { in RunTest()
/external/grpc-grpc-java/testing-proto/src/test/java/io/grpc/testing/protobuf/
DSimpleServiceTest.java21 import static io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING;
67 assertEquals(SERVER_STREAMING, genericTypeShouldMatchWhenAssigned.getType()); in serviceMethodDescriotrs()
/external/grpc-grpc/include/grpcpp/impl/codegen/
Drpc_method.h34 SERVER_STREAMING, // response streaming enumerator
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestCases.java36 SERVER_STREAMING("single request with response streaming"), enumConstant
DTestServiceClient.java253 case SERVER_STREAMING: in runTest()
DStressTestClient.java470 case SERVER_STREAMING: in runTestCase()
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/
D_intraop_test_case.py33 methods.TestCase.SERVER_STREAMING.test_interoperability(self.stub, None)
Dmethods.py464 SERVER_STREAMING = 'server_streaming' variable in TestCase
485 elif self is TestCase.SERVER_STREAMING:
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DMethodDescriptor.java95 SERVER_STREAMING, enumConstant
116 return this == UNARY || this == SERVER_STREAMING; in clientSendsOneMessage()
/external/flatbuffers/tests/
Dmonster_test.grpc.fb.cc33 …d_Retrieve_(MonsterStorage_method_names[1], ::grpc::internal::RpcMethod::SERVER_STREAMING, channel) in Stub()
94 ::grpc::internal::RpcMethod::SERVER_STREAMING, in Service()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DStressTestClientTest.java93 new TestCaseWeightPair(TestCases.SERVER_STREAMING, 30)); in allCommandlineSwitchesAreSupported()
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/
DMetricsServiceGrpc.java37 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
46 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getGetAllGaugesMethod()
DTestServiceGrpc.java137 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
146 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getStreamingOutputCallMethod()
/external/grpc-grpc/src/cpp/server/
Dserver_cc.cc149 method->method_type() == internal::RpcMethod::SERVER_STREAMING), in SyncRequest()
483 case internal::RpcMethod::SERVER_STREAMING: in PayloadHandlingForMethod()
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/
DSimpleServiceGrpc.java104 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
113 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getServerStreamingRpcMethod()
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/
DBenchmarkServiceGrpc.java133 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
142 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getStreamingFromServerMethod()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DClientCallImpl.java105 || method.getType() == MethodType.SERVER_STREAMING; in ClientCallImpl()
/external/flatbuffers/tests/MyGame/Example/
DMonsterStorageGrpc.java115 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getRetrieveMethod()
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/
DServerCallsTest.java72 .setType(MethodDescriptor.MethodType.SERVER_STREAMING)
/external/grpc-grpc-java/compiler/src/test/golden/
DTestService.java.txt72 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
81 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
/external/grpc-grpc-java/compiler/src/testLite/golden/
DTestService.java.txt71 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
80 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpClientTransport.java374 if ((stream.getType() != MethodType.UNARY && stream.getType() != MethodType.SERVER_STREAMING) in startStream()
/external/grpc-grpc-java/compiler/src/testNano/golden/
DTestService.java.txt76 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)

12