| /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/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | server_interceptor.h | 59 enum class Type { UNARY, CLIENT_STREAMING, SERVER_STREAMING, BIDI_STREAMING }; enumerator
88 static_assert(Type::SERVER_STREAMING ==
89 static_cast<Type>(internal::RpcMethod::SERVER_STREAMING),
|
| D | client_interceptor.h | 74 SERVER_STREAMING, enumerator
107 static_assert(Type::SERVER_STREAMING ==
108 static_cast<Type>(internal::RpcMethod::SERVER_STREAMING),
|
| D | rpc_method.h | 34 SERVER_STREAMING, // response streaming enumerator
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | server_interceptor.h | 59 enum class Type { UNARY, CLIENT_STREAMING, SERVER_STREAMING, BIDI_STREAMING }; enumerator
88 static_assert(Type::SERVER_STREAMING ==
89 static_cast<Type>(internal::RpcMethod::SERVER_STREAMING),
|
| D | client_interceptor.h | 74 SERVER_STREAMING, enumerator
107 static_assert(Type::SERVER_STREAMING ==
108 static_cast<Type>(internal::RpcMethod::SERVER_STREAMING),
|
| D | rpc_method.h | 34 SERVER_STREAMING, // response streaming enumerator
|
| /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
|
| /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/pigweed/pw_protobuf/py/pw_protobuf/ |
| D | proto_tree.py | 328 SERVER_STREAMING = 'kServerStreaming' variable in ProtoServiceMethod.Type
350 return (self._type is self.Type.SERVER_STREAMING
450 method_type = ProtoServiceMethod.Type.SERVER_STREAMING
|
| /external/pigweed/pw_rpc/py/pw_rpc/ |
| D | descriptors.py | 184 SERVER_STREAMING = 1 variable in Method.Type
209 return self.Type.SERVER_STREAMING
|
| D | codegen_nanopb.py | 83 elif method.type() == ProtoServiceMethod.Type.SERVER_STREAMING:
|
| D | codegen.py | 203 if method.type() is ProtoServiceMethod.Type.SERVER_STREAMING:
|
| /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/services/src/generated/main/grpc/io/grpc/health/v1/ |
| D | HealthGrpc.java | 69 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
78 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) in getWatchMethod()
|
| /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()
|
| /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()
|