/external/grpc-grpc-java/core/src/test/java/io/grpc/ |
D | MethodDescriptorTest.java | 58 .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/ |
D | stress_interop_client.h | 44 SERVER_STREAMING, enumerator 64 {SERVER_STREAMING, "server_streaming"},
|
D | stress_interop_client.cc | 140 case SERVER_STREAMING: { in RunTest()
|
/external/grpc-grpc-java/testing-proto/src/test/java/io/grpc/testing/protobuf/ |
D | SimpleServiceTest.java | 21 import static io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING; 67 assertEquals(SERVER_STREAMING, genericTypeShouldMatchWhenAssigned.getType()); in serviceMethodDescriotrs()
|
/external/grpc-grpc/include/grpcpp/impl/codegen/ |
D | rpc_method.h | 34 SERVER_STREAMING, // response streaming enumerator
|
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
D | TestCases.java | 36 SERVER_STREAMING("single request with response streaming"), enumConstant
|
D | TestServiceClient.java | 253 case SERVER_STREAMING: in runTest()
|
D | StressTestClient.java | 470 case SERVER_STREAMING: in runTestCase()
|
/external/grpc-grpc/src/python/grpcio_tests/tests/interop/ |
D | _intraop_test_case.py | 33 methods.TestCase.SERVER_STREAMING.test_interoperability(self.stub, None)
|
D | methods.py | 464 SERVER_STREAMING = 'server_streaming' variable in TestCase 485 elif self is TestCase.SERVER_STREAMING:
|
/external/grpc-grpc-java/core/src/main/java/io/grpc/ |
D | MethodDescriptor.java | 95 SERVER_STREAMING, enumConstant 116 return this == UNARY || this == SERVER_STREAMING; in clientSendsOneMessage()
|
/external/flatbuffers/tests/ |
D | monster_test.grpc.fb.cc | 33 …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/ |
D | StressTestClientTest.java | 93 new TestCaseWeightPair(TestCases.SERVER_STREAMING, 30)); in allCommandlineSwitchesAreSupported()
|
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ |
D | MetricsServiceGrpc.java | 37 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) 46 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getGetAllGaugesMethod()
|
D | TestServiceGrpc.java | 137 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) 146 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getStreamingOutputCallMethod()
|
/external/grpc-grpc/src/cpp/server/ |
D | server_cc.cc | 149 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/ |
D | SimpleServiceGrpc.java | 104 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/ |
D | BenchmarkServiceGrpc.java | 133 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/ |
D | ClientCallImpl.java | 105 || method.getType() == MethodType.SERVER_STREAMING; in ClientCallImpl()
|
/external/flatbuffers/tests/MyGame/Example/ |
D | MonsterStorageGrpc.java | 115 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getRetrieveMethod()
|
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
D | ServerCallsTest.java | 72 .setType(MethodDescriptor.MethodType.SERVER_STREAMING)
|
/external/grpc-grpc-java/compiler/src/test/golden/ |
D | TestService.java.txt | 72 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) 81 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|
/external/grpc-grpc-java/compiler/src/testLite/golden/ |
D | TestService.java.txt | 71 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/ |
D | OkHttpClientTransport.java | 374 if ((stream.getType() != MethodType.UNARY && stream.getType() != MethodType.SERVER_STREAMING) in startStream()
|
/external/grpc-grpc-java/compiler/src/testNano/golden/ |
D | TestService.java.txt | 76 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
|